Java8流的顺序执行和并行执行产生不同的结果？

Question

在Java8中运行以下流示例：

    System.out.println(Stream
        .of("a", "b", "c", "d", "e", "f")
        .reduce("", (s1, s2) -> s1 + "/" + s2)
    );

产量：

/a/b/c/d/e/f

当然-这并不奇怪。由于http://docs.oracle.com/javase/8/docs/api/index.html?overview-
summary.html
，流是顺序执行还是并行执行都没有关系：

除了标识为明确不确定的操作（例如findAny（））之外，流是顺序执行还是并行执行都不应该更改计算结果。

AFAIK reduce()是确定性的并且(s1, s2) -> s1 + "/" + s2是关联的，因此加法parallel()应产生相同的结果：

    System.out.println(Stream
            .of("a", "b", "c", "d", "e", "f")
            .parallel()
            .reduce("", (s1, s2) -> s1 + "/" + s2)
    );

但是我的机器上的结果是：

/a//b//c//d//e//f

怎么了

顺便说一句：使用（首选）.collect(Collectors.joining("/"))而不是reduce(...)产生相同的结果a/b/c/d/e/f顺序执行和并行执行。

JVM详细信息：

java.specification.version: 1.8
java.version: 1.8.0_31
java.vm.version: 25.31-b07
java.runtime.version: 1.8.0_31-b13

Answer 1

从reduce的文档中：

身份值必须是累加器功能的身份。这意味着对于所有t，accumulator.apply（identity，t）等于t。

在您的情况下，这是不正确的-“”和“ a”创建了“ / a”。

我已经提取了累加器功能并添加了打印输出以显示发生了什么：

BinaryOperator<String> accumulator = (s1, s2) -> {
    System.out.println("joining \"" + s1 + "\" and \"" + s2 + "\"");
    return s1 + "/" + s2;
};
System.out.println(Stream
                .of("a", "b", "c", "d", "e", "f")
                .parallel()
                .reduce("", accumulator)
);

这是示例输出（运行之间有所不同）：

joining "" and "d"
joining "" and "f"
joining "" and "b"
joining "" and "a"
joining "" and "c"
joining "" and "e"
joining "/b" and "/c"
joining "/e" and "/f"
joining "/a" and "/b//c"
joining "/d" and "/e//f"
joining "/a//b//c" and "/d//e//f"
/a//b//c//d//e//f

您可以在函数中添加if语句以分别处理空字符串：

System.out.println(Stream
        .of("a", "b", "c", "d", "e", "f")
        .parallel()
        .reduce((s1, s2) -> s1.isEmpty()? s2 : s1 + "/" + s2)
);

正如Marko Topolnik所注意到的，s2由于累加器不必是可交换的函数，因此不需要进行检查。