Stream 在顺序模式下工作，但在并行模式下有问题

Question

目前我正在阅读Java 8 Lambdas: Pragmatic Functional Programming（非常有趣且写得很好的书，没有推荐）。

在第 6 章之后有一个练习：

代码将列表中的每个数字相乘，然后将 结果由 5. 顺序运行正常，但并行运行时有bug。

public static int multiplyThrough(List<Integer> linkedListOfNumbers) {
    return linkedListOfNumbers.parallelStream()
                       .reduce(5, (acc, x) -> x * acc);
}

以及解决方案：

public static int multiplyThrough(List<Integer> numbers) {
    return 5 * numbers.parallelStream()
                      .reduce(1, (acc, x) -> x * acc);
}

我不明白为什么第一种方法在并行模式下是错误的，并且书中没有解释。

请解释一下。

Answer 1

javadoc 说：

标识值必须是累加器函数的标识。这意味着对于所有 t，accumulator.apply(identity, t) 等于 t。累加器函数必须是关联函数。

在您的第一个示例中显然不是这种情况：

5 * x 不等于 x。

它在并行模式下没有给出相同结果的原因是，在这种模式下，流被分割成块，并且对每个块应用缩减，然后每个块的结果被缩减。所以你最终乘以 5 几次，而在顺序模式下，乘以 5 只发生一次。