为什么组合器对输出没有影响？ [复制]

Question

以下代码输出一直是24。

public static void main(String[] args) throws InterruptedException {
    List<String> list = new ArrayList<String>();
    list.add("java");
    list.add("php");
    list.add("python");
    list.add("perl");
    list.add("c");
    list.add("lisp");
    list.add("c#");
    int s = list.stream().reduce(0, (x, y) -> x + y.length(), (x, y) -> 0);
    System.out.println(s);
    s = list.stream().reduce(0, (x, y) -> x + y.length(), (x, y) -> x - y);
    System.out.println(s);
    s = list.stream().reduce(0, (x, y) -> x + y.length(), (x, y) -> x * y);
    System.out.println(s);

}   

问题是为什么组合器会影响我的代码。

Answer 1

combiner 仅用于并行流。

但是即使您添加parallel，您的代码也可能存在其他问题。他们都违反了一些规则……具体来说：

另外，combiner 函数必须与 accumulator 函数兼容；对于所有 u 和 t，以下必须成立

 combiner.apply(u, accumulator.apply(identity, t)) == accumulator.apply(u, t)

您的组合器违反了这一点，因此取决于您拥有的 CPU 数量 - 您会得到不同的结果 - 这显然是错误的。

Answer 2

如果减少并行Stream，combiner 会影响结果。对于连续的Stream，不需要组合部分结果。

例如，当我在您的代码中将 stream() 更改为 parallelStream() 时，我得到：

0
6
2304

当然，您提供的所有组合器都是坏组合器。您应该提供一个不影响reduce的最终结果的组合器。