平行流API中的波动性

Question

请参阅下面的JDK流API收集器之一：

    public static <T> Collector<T, ?, Integer>
    summingInt(ToIntFunction<? super T> mapper) {
        return new CollectorImpl<>(
                () -> new int[1],
                (a, t) -> { a[0] += mapper.applyAsInt(t); },
                (a, b) -> { a[0] += b[0]; return a; },
                a -> a[0], CH_NOID);
    }

考虑使用并行处理，很明显，在任何同步中都不需要，并且可以安全地使用非电流容器（） - ＆gt;新的int [1]，由于每个这样的容器都是创建并填充累加器（a，t） - ＆gt; {a [a [0] += mapper.applyasint（t）; }在单独的线程中。然后将所有这些容器组合在单独的线程中，并使用组合仪（a，b） - ＆gt组合； {a [0] += b [0];返回a; }进入最终结果。

同时，JLS假定如果该字段以某种方式在另一个线程中更新（由于线程缓存和其他JMM功能），则读取器线程可能不会看到非易失性字段的实际值。但是考虑到示例收集器，您可以看到使用了一个普通的int阵列，其元素并不动摇。我无法弄清楚为什么在这里使用普通的int数组，而不是例如atomicintegerarray，当非挥发元素int [0]在一个线程中更新，然后在其他线程中读取执行组合。

您能解释一下为什么使用并行处理在流中使用具有非易失性力学的容器是安全的吗？

Answer 1

它的工作方式是，每个并行线程都会收到其自己的个人副本（一个元素int数组），它们相互独立更新。阵列访问无需挥发性。

一旦线程用完源值，他们就会使用一个记忆障碍，以确保其单个数组进入正确发布，然后彼此“跳舞”以执行这些单个容器的组合。然后，每个这样的组合都具有另一个记忆障碍。这一直持续到只有一个容器。

实际实施涉及更多。查看 ReferencePipeline.Collect 。