Java流：区别为每个和每个排序

Question

前提：我已经读过这个问题和其他问题，但我需要一些澄清。

我理解这条流。forEach方法不仅在处理并行流时起作用，这也解释了为什么

//1
Stream.of("one ","two ","three ","four ","five ","six ")
.parallel()
.forEachOrdered(item -> System.out.print(item));

印刷品

one two three four five six

但当涉及到中间操作时，当流被并行化时，顺序就不再有保障了。所以这个代码

//2
Stream.of("one ","two ","three ","four ","five ","six ")
.parallel()
.peek(item -> System.out.print(item))
.forEachOrdered(item -> System.out.print(""));

会打印一些类似

four six five one three two 

说forEachOrded方法只影响其自身执行中元素的顺序是正确的吗？直观地说，我认为//1示例与

//3
Stream.of("one ","two ","three ","four ","five ","six ")
.parallel()
.peek(item -> System.out.print("")) //or any other intermediate operation
.sequential()
.forEach(item -> System.out.print(item));

我的直觉错了吗？我是不是遗漏了整个机制的一些东西？

Answer 1

#3代码在概念上并不等同于#1，因为parallel（）或sequential（）调用影响整个流，而不仅仅是后续操作。所以在#3的情况下，整个过程将按顺序进行。实际上#3案例类似于流API的早期设计，当您实际上可以更改并行/顺序模式时。这被认为是不必要的复杂化（实际上增加了问题，例如，请参见本讨论），因为通常您只需更改模式即可使终端操作有序（但不一定是顺序的）。因此，添加了forEachOrdered（），并更改了parallel（）/sequential（）语义，以影响整个流（请参见此变更集）。

基本上你是对的：在并行流中，中间操作没有顺序保证。如果需要按特定顺序执行，则必须使用顺序流。

Answer 2

你是对的，对forEachOrdered行动的保证只适用于该行动，其他什么都不适用。但是，假设这与相同是错误的。顺序（）。forEach（…）。

sequential将使整个流管道进入顺序模式，因此，传递给forEach的操作将由同一线程执行，但也由前面的peek操作执行。对于大多数中间操作来说，parallel或sequential的确切位置是不相关的，指定这两种操作没有意义，因为只有最后一种操作才相关。

此外，在使用forEach时，仍然无法保证订购，即使它在当前的实现中没有任何后果。这在“Stream.forEach是否尊重连续流的相遇顺序”中讨论

流的文档。forEachOrdered声明：

此操作一次处理一个元素，如果存在，则按相遇顺序处理。对一个元素执行操作发生在对后续元素执行操作之前，但对于任何给定元素，操作可以在库选择的任何线程中执行。

因此，动作可能会被不同的线程调用，这可以被Thread.currentThread（）感知到，但不会同时运行。此外，如果流有遭遇顺序，它将在此处重新构建。这个答案揭示了遭遇顺序和处理顺序的区别。