ConcurrentModificationException错误的原因及解决

ConcurrentModificationException异常的原因及解决
    今天在对map进行遍历的程序中发现抛出ConcurrentModificationException 异常：

    一个线程中：

Map<byte[],byte[]> map = new ConcurrentHashMap<byte[],byte[]>();while((row = results.next()) != null){map.clear();...queue.put(map);}

    另一个线程中：

while(queue.size() > 0){line = queue.poll();if(line == null)continue;Iterator<Map.Entry<byte[],byte[]>> it = line.entrySet().iterator();while(it.hasNext()){...}}

    即使读写线程分别只用一个，也会抛出该异常。

    原因是Iterator是工作在一个独立的线程中，并且拥有一个 mutex 锁。 Iterator 被创建之后会建立一个指向原来对象的单链索引表，当原来的对象数量发生变化时，这个索引表的内容不会同步改变，所以当索引指针往后移动的时候就找不到要迭代的对象，所以按照 fail-fast 原则 Iterator 会马上抛出 java.util.ConcurrentModificationException 异常。
(http://www.iteye.com/topic/124788)

    所以当读线程中执行了map.clear()后，写线程的Iterator指向的原始对象就变化了，导致抛出异常。修改读线程代码为：

Map<byte[],byte[]> map;while((row = results.next()) != null){map = new ConcurrentHashMap<byte[],byte[]>();...queue.put(map);}

    问题解决。
恩，大师，ConcurrentModificationException 是从List中抛出的，这里就是queue。当map执行clear后，再去访问原来put到queue中的元素后就出错了。我代码可能没有引用完

查看更多 下一篇