ConcurrentHashMap 的 ConcurrentModificationException

Question

我理解它背后的概念，但认为使用 ConcurrentHashMap 而不是 HashMap 可以解决它。因为ConcurrentHashMap可以防止不同线程的并发读取和修改。

但我仍然看到异常。

这是代码片段-

示例文件.java

prepareInfo(RequestHelper.getSender(request), someVar, concurrentMap);
....
...
    private void prepareInfo(final Sender sender, final SomeVar someVar, final ConcurrentHashMap<String,
            Object> concurrentMap){
        final Info info = RequestHelper.getInfo(someVar);
        someVar.setInfo(info);
        if(sender != null){
            prepareProfileInfo(sender.getUserDetails(), info, concurrentMap);
            mapDetailsWithMap(sender.getDetails(), concurrentMap);
            if(sender.getSenderId() != null){
                concurrentMap.put("sender_id", sender.getSenderId());
            }
            concurrentMap.putAll(sender.getAdditionalProperties());
        }
    }

错误堆栈跟踪是 -

    at java.util.HashMap$HashIterator.nextNode(HashMap.java:1445)
    at java.util.HashMap$EntryIterator.next(HashMap.java:1479)
    at java.util.HashMap$EntryIterator.next(HashMap.java:1477)
    at java.util.concurrent.ConcurrentHashMap.putAll(ConcurrentHashMap.java:1083)
    at SampleFile.prepareAccountInfo(SampleFile.java:114)

有几个问题我不太清楚-

1. 为什么还是出现异常？
2. 我们有办法通过单元测试来测试修复吗？

Answer 1

此行使用

sender.getAdditionalProperties()

检索 HashMap，然后迭代 HashMap，将每个项目添加到

concurrentMap

：

        concurrentMap.putAll(sender.getAdditionalProperties());

如果在迭代运行时修改

HashMap

中的

sender

，您将收到 ConcurrentModificationException。异常意味着“当我迭代地图时，地图的结构被修改了，所以我不知道现在该怎么办”。

为了允许在

sender

对象内的地图上进行并发修改和迭代，该地图应该是

ConcurrentHashMap

。

要测试修复，您可以进行以下测试：

Map<String,Object> map =  sender.getAdditionalProperties()
map.put("foo", "bar");
Iterator<Map.Entry<String, Object>> iterator = map.entrySet().iterator();
// uh-oh - adding an item invalidates HashMap iterator
map.put("bar", "baz");
// Throws exception for HashMap
iterator.next();

Answer 2

您犯了一个可以理解且非常常见的错误。

你看到了

ConcurrentModificationException

，你就想：嗯。显然，线程。

但这是错误的。这个名字……也许很不幸。

ConcurrentModificationException

与线程无关。

CoModEx 只是意味着这一系列事件已经发生：

1. 您已经从集合中创建了一个迭代器，例如通过调用

   .iterator()

   ，或通过写

   for (var x : someCollection)

   组成 1。
2. 在创建迭代器后的某个时间点，您以某种方式更改了底层集合。您清除了它、向其中添加了某些内容、更新了值或删除了某些内容。任何改变。
3. 您可以对步骤 1 中创建的迭代器执行任何操作，例如对其调用

   .hasNext()

   或

   next()

   ，或者您的

   for (var x : someCollection)

   到达右大括号/您运行

   continue

   。

然后，繁荣。 CoModEx.

这是一个简单的方法。请注意这个应用程序是如何完全单线程的：

class ThisAsplodes {
    public static void main(String[] args) {
        List<String> list = new ArrayList<String>();
        list.add("Okay");
        for (String elem : list) {
            list.add("Bye");
        }
    }
}

编译它，运行它，瞧。并发修改异常。修改列表（添加“Bye”），然后在更改之前创建的迭代器（右大括号）上进行迭代。

它会变得更好：如果您尝试使用简单的哈希图和多个线程（一个线程创建迭代器，另一个线程修改它）来执行这一系列事件，那么 CoModEx 可能会发生，但更常见的是事情会以奇怪的方式中断。例如，您刚刚添加的键似乎不在地图中。

从您的代码中看不出您在哪里执行此操作，但至少现在您知道该在哪里查看。