使用不同的线程删除元素遍历 ConcurrentSkipListSet

Question

我有一个ConcurrentSKipListSet，我正在用一个for-each循环迭代这个集合中的值。另一个线程在某个时候将从此集合中删除一个元素。

我想我遇到了这样一种情况：一个线程删除了一个我尚未迭代的元素（或者我刚刚开始迭代它），因此从循环内进行的调用失败。

为清楚起见，一些代码：

for(Foo foo : fooSet) {
  //do stuff
  //At this point in time, another thread removes this element from the set
  //do some more stuff
  callService(foo.getId()); // Fails
}

阅读文档，我无法确定这是否可能：

迭代器

是弱一致性的，返回的元素反映了在迭代器创建时或自创建以来的某个点的集合状态。它们不会抛出ConcurrentModificationException，并且可以与其他操作同时进行。

那么这是否可能，如果是这样，处理这个问题的好方法是什么？

谢谢

将

Answer 1

我想我遇到了这样一种情况：一个线程删除了一个我尚未迭代的元素（或者我刚刚开始迭代它），因此从循环内进行的调用失败。

我不认为这是javadocs所说的：

迭代器

是弱一致性的，返回的元素反映了在迭代器创建时或自创建以来的某个点的集合状态。它们不会抛出 ConcurrentModificationException，并且可以与其他操作同时进行。

这是说您不必担心在您遍历列表的同时有人从ConcurrentSkipListSet中删除。 但是，当您在迭代器中移动时，肯定会有竞争条件。 foo要么在迭代器获取它后立即删除，要么在迭代器之前被删除并且迭代器看不到它。

callService（foo.getId（））;//这不应该"失败"

如果迭代器返回foo，则服务调用不会"失败"，除非它假设foo仍在列表中并以某种方式对其进行检查。 最坏的情况是，您可能会对foo执行一些操作并使用它调用服务，即使它刚刚被另一个线程从列表中删除。

Answer 2

我也遇到了这个问题，以及由不同线程写入和读取的队列。一种方法是标记而不是删除不再需要的元素。您可以在浏览整个列表后运行清理迭代器。您需要一个全局锁来从列表中删除元素，其余时间您的代码可以并行运行。示意性地它的工作原理是这样的：

writer:
  while() {
    set.add(something);
    something.markForDelete();
  }
reader:
  while() {
    // process async
    iterator iter = set.getIterator();
    for(iter.hasNext()) {
      ... work, check isMarkedForDelete() ...
    }
    iter = set.getIterator();
    // delete, sync
    globalLock.Lock();
    for(iter.hasNext()) {
      if(something.isMarkedForDelete()) {
      set.remove(something);
    }
    globalLock.Unlock();
  }
}