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

此行使用 检索 HashMap sender.getAdditionalProperties()，然后迭代 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)生成一个迭代器。
2. 在创建迭代器后的某个时间点，您以某种方式更改了底层集合。您清除了它、向其中添加了某些内容、更新了值或删除了某些内容。任何改变。
3. 您可以对步骤 1 中创建的迭代器执行任何操作，例如调用.hasNext()or 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 可能会发生，但更常见的是事情会以奇怪的方式中断。例如，您刚刚添加的键似乎不在地图中。使用ConcurrentHashMap，您可以可靠地获得CoModEx。

从您的代码来看，您在哪里执行此操作并不明显，但至少现在您知道该在哪里查找。