Collections.synchronized 映射是否使迭代器线程安全

Question

系统中有两个线程。一个是读取线程，另一个是写入线程。

使用以下代码同步地图。

Map<String,ArrayList<String>> m = Collections.synchronizedMap(new HashMap<String,ArrayList<String>())

读取线程获取映射值的迭代器，同时写入线程修改映射。

那么，我的问题是迭代器会抛出ConcurrentModificationException吗？

Answer 1

也许吧。这样做是不安全的。 documentation 说

当迭代任何集合视图时，用户必须在返回的地图上手动同步

Collections.synchronized... 使单个方法调用原子化，因此它们不需要进一步同步。但是迭代不仅仅是一个单一的方法调用，所以它需要额外的同步。下面是一个例子

    Map<String, String> shared = Collections.synchronizedMap(new HashMap<>());

    new Thread(() -> {
        while (true) {
            synchronized (shared) {
                for (String key : shared.keySet()) {
                    System.out.println(key);
                }
            }
            try {
                Thread.sleep(1000);
            } catch (Exception e) {
                break;
            }
        }
    }).start();

    new Thread(() -> {
        while (true) {
            try {
                // this is atomic
                shared.put(UUID.randomUUID().toString(), "Yo!");
                Thread.sleep(1000);
            } catch (Exception e) {
                break;
            }
        }
    }).start();
}

Answer 2

是的，Iterator 可能仍会抛出 ConcurrentModificationException，因为它与同步无关（尽管它的名字暗示了）。Iterator 尝试尽最大努力检测结构修改（添加或删除对象）尝试并且与 List 的操作是否同步无关。 一旦通过List.iterator() or List.listIterator() 获得迭代器，对列表所做的任何更改（除了迭代器本身）都将尽最大努力引发 CME 异常。 确保不抛出 ConcurrentModificationException 的唯一方法 要么先完成阅读器操作，然后完成写入器操作（反之亦然），要么使用来自ConcurrentHashMap的故障安全迭代器

Map hashmap = new HashMap<String,ArrayList<String>();
----

Map<String,ArrayList<String>> m = new ConcurrentHashMap<String,ArrayList<String>(hashmap));

ConcurrentHashMap 是一个故障安全迭代器，现在您可以专注于同步读写器操作，而不是担心 ConcurrentModificationException。