哈希映射和可见性
如果在创建迭代器后的任何时间对映射进行了结构修改,则除了通过迭代器自己的 remove 方法之外,迭代器将抛出 ConcurrentModificationException。
我构建了一个示例代码,该代码基于规范,应该几乎立即失败并抛出一个 ConcurrentModificationException;
- 它确实会像Java 7中预期的那样立即失败
- 但它(似乎)总是与Java 6一起使用(即它不会引发承诺的异常)。
注意:它有时在Java 7中不会失败(比如20个时间中的1个) - 我想它与线程调度有关(即2个runnable不是交错的)。
我错过了什么吗?为什么使用Java 6运行的版本没有抛出一个ConceptModificationException?
实质上,有 2 个可运行的任务并行运行(倒计时用于使它们大约同时启动):
- 一种是向地图添加项目
- 另一个是迭代地图,读取键并将它们放入数组中
然后,主线程检查已添加到数组中的键数。
Java 7 典型输出(迭代立即失败):
java.util.ConcurrentModificationException
MAX i = 0
Java 6 的典型输出(整个迭代通过,数组包含所有添加的键):
最大 i = 99
使用的代码:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
final int SIZE = 100;
final Map<Integer, Integer> map = new HashMap<Integer, Integer>();
map.put(1, 1);
map.put(2, 2);
map.put(3, 3);
final int[] list = new int[SIZE];
final CountDownLatch start = new CountDownLatch(1);
Runnable put = new Runnable() {
@Override
public void run() {
try {
start.await();
for (int i = 4; i < SIZE; i++) {
map.put(i, i);
}
} catch (Exception ex) {
}
}
};
Runnable iterate = new Runnable() {
@Override
public void run() {
try {
start.await();
int i = 0;
for (Map.Entry<Integer, Integer> e : map.entrySet()) {
list[i++] = e.getKey();
Thread.sleep(1);
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
};
ExecutorService e = Executors.newFixedThreadPool(2);
e.submit(put);
e.submit(iterate);
e.shutdown();
start.countDown();
Thread.sleep(100);
for (int i = 0; i < SIZE; i++) {
if (list[i] == 0) {
System.out.println("MAX i = " + i);
break;
}
}
}
}
注意:在 x86 计算机上使用 JDK 7u11 和 JDK 6u38(64 位版本)。