ConcurrentHashMap 迭代器保证

Question

鉴于 ConcurrentHashMap javadocs 状态：

"迭代器和枚举返回反映状态的元素 在迭代器创建时或之后的某个时间点的哈希表”

我想我可以保证在下面的示例中，一个或两个线程将调用 fireAllFinished()。有没有调用fireAllFinished()的情况？

ConcurrentHashMap<String, Boolean> taskToFinished = new ConcurrentHashMap();
    taskToFinished.put("taskA", false);
    taskToFinished.put("taskB", false);

public void checkForAllFinished() {
    boolean allFinished = true;
    for (Boolean taskFinished = tasksToFinished.values()) {
        if (!taskFinished) {
            allFinished = false;
            break;
        }
    }
    if (allFinished) {
       fireAllFinished()
    }
}

//Thread1
public void run() {
    taskToFinished.put("taskA", true);
    checkForAllFinished();
}

//Thread1
public void run() {
    taskToFinished.put("taskB", true);
    checkForAllFinished();
}

（我省略了一些线程创建代码。希望意图清楚）

更新：我已经看到了这个更笼统的问题：Is iterating ConcurrentHashMap values thread safe?，但想确认我的具体观点为

“在某个时候”

在处理乱序运行代码的多核机器时通常是一个不精确的概念，两个线程可能“同时”更新映射的不同段，并且设计上没有办法锁定整个 ConcurrentHashMap。

Answer 1

阅读ConcurrentHashMap的文档...

检索反映了最近完成的更新操作在开始时保持的结果。 （更正式地说，给定键的更新操作与报告更新值的键的任何（非空）检索具有发生前的关系。）

和

对于 putAll 和 clear 等聚合操作，并发检索可能仅反映插入或删除某些条目。类似地，迭代器、拆分器和枚举返回的元素反映了在迭代器/枚举创建时或之后的某个时刻哈希表的状态。

措辞不明确，但最近完成和at or since应该意味着map操作和迭代器创建是顺序一致的。

使用您的示例，如果我们调用 map put A，并进行值检查 B 你有......

T1：A -> B

T2：A -> B

A发生在B之前，但T1和T2同时发生。顺序一致的意思是，只要 A 发生在 B 之前，一些 两者之间的有效序列就需要发生。但是，T1 和 T2 之间的任何排序都是有效的。

例如

T1:A -> T1:B -> T2:A -> T2:B

T1:A -> T2:A -> T2:B -> T1:B

因此，当代码实际运行时，任何有效的排序都可能发生，但 T1:B 或 T2:B（检查）必须最后发生。因此，fireAllFinished 被调用一次或两次。线性同步将进一步限制为所有事件之间的显式排序。

虽然迭代整个地图可能有点贵，但使用AtomicInteger 或其他同步机制（如ConcurrentLinkedQueue）可能更简单。