java - 同步方法的 ConcurrentModificationException

Question

我正在处理大量来自 TCP 套接字的事件(每秒十个)，所以我使用多线程来处理这些事件。

public class MainActivity extends Activity {
  ...

  // In this Map I store the tab name and the associated TabHost.TabSpec instance
  private static Map<String, TabHost.TabSpec> Tabs = Collections.synchronizedMap(new LinkedHashMap<String, TabHost.TabSpec>());
  // In this Map I store pairs of tab-names and a HashSet of undelivered messages
  // It's a class that extends Map<String, HashSet<String>> with some additional functions that doesn't have anything to do with Tabs.
  private static NamesListing Names = Collections.synchronizedMap(new LinkedHashMap<String, HashSet<String>>());

  // Yes, I know the names don't follow the Java standards, but I keeped them for mantaining the question coherence. I will change it in my code, though.

  synchronized private static void ProcessEvent(final String name, final String message) {
    // Low-priority thread
    final Thread lowp = new Thread(
      new Runnable() { 
        public void run() {
          final Iterator<String> iter = Tabs.keySet().iterator();
          while (iter.hasNext()) {
            final String tabname = iter.next();
            // This just returns an int making some calculations over the tabname
            final int Status = Names.getUserStatus(tabname, message);

            // Same than getUserStatus
            if ((Names.isUserSpecial(Status)) && (name.equals(tabname))) {
              // This just removes a line from the HashSet
              Names.delLine(tabname, message);
            }
          }
        }
      });
    lowp.setPriority(3);
    lowp.start();
  }

  ...
}

大多数情况下这都能正常工作，但有时这些事件会大量涌现，有时我会得到一个 ConcurrentModificationException:

12-10 14:08:42.071: E/AndroidRuntime(28135): FATAL EXCEPTION: Thread-369 12-10 14:08:42.071: E/AndroidRuntime(28135): java.util.ConcurrentModificationException 12-10 14:08:42.071: E/AndroidRuntime(28135): at java.util.LinkedHashMap$LinkedHashIterator.nextEntry(LinkedHashMap.java:347) 12-10 14:08:42.071: E/AndroidRuntime(28135): at java.util.LinkedHashMap$KeyIterator.next(LinkedHashMap.java:367) 12-10 14:08:42.071: E/AndroidRuntime(28135): at es.irchispano.chat.MainActivity$6.run(MainActivity.java:244) 12-10 14:08:42.071: E/AndroidRuntime(28135): at java.lang.Thread.run(Thread.java:841)

注:244行对应

final String tabname = iter.next();

声明。

这对我来说似乎很奇怪，因为我正在使用 Collections.synchronizedMap 并且处理这些行的方法是同步的，那么为什么它仍然发生？

谢谢!

------------ 已编辑------------

对于简洁的初始代码感到抱歉；我试图尽可能地简化，但显然这不是一个好主意。我正在粘贴实际代码。当然，这些结构中的每一个都已初始化(否则我不会有问题:-))，现在我将带着良心阅读您的所有评论，然后我将发布我发现的内容。谢谢大家的支持!

Answer 1

您向我们展示了 map Tabs 是如何创建的(Java 命名约定规定其名称以小写字母开头)，但没有展示它是如何填充的。事实上，映射总是空的，而 while 循环将运行零次。此外，局部变量 tabname 未使用，但可能在您的实际代码中未使用。

也就是说，似乎 ProcessEvent 将为每个事件运行一次。它是静态的，并且是同步的，这意味着它将获得 MainActivity.class, 的监视器，并且不能同时运行在同一对象上同步的其他方法。

但是，它会启动一个新线程，该线程执行实际工作并立即返回。该线程不是同步的，因此可以同时运行任意数量的这些工作线程，它们都使用同一个映射。 map 用 Collections.synchronizedMap 包装，这是防止并发修改的唯一保护措施。

这样的synchronized map不会让多个调用者同时调用它的方法，但是对不同方法的单独调用可以任意交错。例如，当一个调用者将新条目放入 map 时，其他调用者无法访问该 map 。但是，一个调用者可以从映射中获取键集，从键集中获取迭代器，并开始对其进行迭代，然后另一个线程中的另一个调用者可以添加、修改或删除条目，并且，最后，第一个线程继续遍历键集并获得 ConcurrentModificationException。

我建议改用 java.util.concurrent.ConcurrentHashMap，并从 ProcessEvent. 中删除同步关键字。