ConcurrentHashMap的ConcurrentModificationException

编程问答 2022-11-12

问题描述

我了解其背后的概念，但认为使用ConcurrentHashMap代替HashMap可以解决此问题。因为ConcurrentHashMap可以防止由不同线程进行的并发读取和修改。

但是我仍然看到异常。

这是代码段-

SampleFile.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. 有没有一种方法可以通过单元测试来测试修订？

解决方法

此行使用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();
,

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

您看到了ConcurrentModificationException，并想：呵呵。显然是线程。

但这是错误的。这个名字是...很不幸。

ConcurrentModificationException与线程无关。

CoModEx仅表示发生了以下事件序列：

  1. 您已经从集合中创建了一个迭代器，例如通过调用.iterator()或写成for (var x : someCollection)的电话。
  2. 进行该迭代器后的某个时间点，您将以某种方式更改基础集合。您清除了它，添加了一些东西，更新了一个值，或者删除了一些东西。根本没有任何变化。
  3. 您可以使用第1步中生成的迭代器执行任何操作，例如在其上调用.hasNext()或next()，或者您的for (var x : someCollection)到达右括号/您运行{{1 }}。

然后，繁荣。 CoModEx。

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

continue

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

它甚至变得更好：如果您尝试使用简单的jane hashmap和多个线程（一个线程使迭代器，另一个线程对其进行修改）执行此事件序列，则可能会发生CoModEx，但通常情况下，事情只会变得奇怪方法。例如，您刚刚添加的键似乎不在地图中。使用ConcurrentHashMap，您可以可靠地获取CoModEx。

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

collectionscollectionsconcurrentmodificationiterationiterationjavajava