Guava MultiMap 和 ConcurrentModificationException

Question

我不明白为什么当我迭代此 multimap 时会收到 ConcurrentModificationException。 我阅读了以下内容 条目，但我不确定我是否理解了整个事情。 我尝试添加一个同步块。但我的疑问是同步什么以及何时同步。

multimap 是一个字段，创建如下：

private Multimap<GenericEvent, Command> eventMultiMap =   
   Multimaps.synchronizedMultimap(HashMultimap.<GenericEvent, Command> create());

并使用如下：

eventMultiMap.put(event, command);

并且像这样（我尝试在地图上同步这部分，但没有成功）

for (Entry<GenericEvent, Command> entry : eventMultiMap.entries()) {
    if (entry.getValue().equals(command)) {
        eventMultiMap.remove(entry.getKey(), entry.getValue());
        nbRemoved++;
    }
}

Answer 1

在迭代集合时调用remove每次都会导致ConcurrentModificationException，即使这一切都是在同一个线程中完成的 - 正确的做法是获取一个显式迭代器并对其调用.remove()。

编辑：修改您的示例：

Iterator<Map.Entry<GenericEvent, Command>> i = eventMultiMap.entries().iterator();
while (i.hasNext()) {
    if (i.next().getValue().equals(command)) {
        i.remove();
        nbRemoved++;
    }
}

Answer 2

您可能希望查看这篇博文，了解另一个陷阱遍历多重映射时发生 ConcurrentModificationException，且没有其他线程干扰。简而言之，如果您遍历 multimap 的键，访问与每个键关联的相应值集合，并从该集合中删除某个元素，如果该元素恰好是该集合的最后一个，您将当您尝试访问下一个键时，会出现 ConcurrentModificationException ，因为清空集合会触发该键的删除，从而在结构上修改多重映射的键集。

Answer 3

如果另一个线程可以在此逻辑运行时修改您的多重映射，则您需要向 MHarris 的代码中添加一个同步块：

synchronized (eventMultimap) {
  Iterator<Entry<GenericEvent, Command>> i = eventMultiMap.entries.iterator();
  while (i.hasNext()) {
    if (i.next().getValue().equals(command)) {
        i.remove();
        nbRemoved++;
    }
  }
}

或者，您可以省略迭代器，如下所示，

synchronized (eventMultimap) {
  int oldSize = eventMultimap.size();
  eventMultimap.values().removeAll(Collections.singleton(command));
  nbRemoved = oldSize - eventMultimap.size();
}

removeAll() 调用不需要同步。但是，如果省略同步块，多重映射可能会在removeAll() 调用和其中一个size() 调用之间发生变化，从而导致nbRemoved 值不正确。

现在，如果您的代码是单线程的，并且您只是想避免 ConcurrentModificationException 调用，则可以省略 Multimaps.synchronizedMultimap 和同步 (eventMultimap) 逻辑。

Answer 4

在java8中，您还可以使用lambda方法：

eventMultiMap.entries().removeIf(genericEventCommandEntry -> genericEventCommandEntry.getValue().equals(command));

Answer 5

如果您不关心密钥，我更喜欢 Multimap.values().iterator() 。您还应该尽量避免使用同步块，因为您无法有效地优先考虑读/写。

ReadWriteLock lock = new ReentrantReadWriteLock();
Lock writeLock = lock.writeLock(); 

public void removeCommands(Command value) {
  try {
    writeLock.lock();
    for (Iterator<Command> it = multiMap.values().iterator(); it.hasNext();) {
      if (it.next() == value) {
        it.remove();
      }
    }
  } finally {
    writeLock.unlock();
  }
}