Java8stream顺序和并行执行产生不同的结果？
在Java8中运行以下stream示例：
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.htmlstream是顺序执行还是并行执行都无关紧要：
除了标识为明确不确定的操作(如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
从减less的文件：
身份值必须是累加器函数的标识。 这意味着对于所有的t，accumulator.apply(identity，t)等于t。
你的情况不是这样 – “”和“a”创build“/ a”。
我已经提取了累加器函数，并添加了一个打印输出来显示发生了什么：
BinaryOperator 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语句到你的函数来分别处理空string：
System.out.println(Stream .of("a", "b", "c", "d", "e", "f") .parallel() .reduce((s1, s2) -> s1.isEmpty()? s2 : s1 + "/" + s2) );
正如Marko Topolnik所注意到的那样，检查s2是不需要的，因为累加器不必是交换function。
要添加到其他答案，
您可能想要使用可变减less ，文档指定做类似的事情
String concatenated = strings.reduce("", String::concat)
会给糟糕的performance结果。
我们会得到期望的结果，甚至可以并行工作。 但是，我们可能不会对表演感到高兴！ 这样的实现会进行大量的string复制，运行时间将会是字符数量的O(n ^ 2)。 更高效的方法是将结果累积到一个StringBuilder中 ，这是一个用于累加string的可变容器。 我们可以使用相同的技术来平行化可变的缩减，就像我们用普通的缩减一样。
所以你应该使用一个StringBuilder来代替。
对于刚开始使用lambda和stream的人来说，花了相当长的时间才能到达“AHA”时刻，直到我真正理解了这里发生的事情。 我会稍微改写一下，以便让我更容易(至less我希望它真的被回答了)像一个像我这样的stream新手。
这一切都在减less文件，指出：
标识值必须是累加器函数的标识。 这意味着对于所有的t，accumulator.apply(identity，t)等于t。
我们可以很容易地certificate代码的方式，关联性被打破：
static private void isAssociative() { BinaryOperator operator = (s1, s2) -> s1 + "/" + s2; String result = operator.apply("", "a"); System.out.println(result); System.out.println(result.equals("a")); }
一个空string连接到另一个string，应该真的产生第二个string; 这不会发生，因此累加器(BinaryOperator)不是关联的，因此reduce方法在并行调用的情况下不能保证相同的结果。
转播
