如何保证java8流中处理的顺序？

Question

我想在xmlJava对象中处理列表。我必须确保处理所有的元素，以便我收到他们。

因此，我是否应该对我使用的每个流调用sequential？List.Stream().Sequential().Filter().Foreach()

或者，只要不使用并行性，只使用流就足够了吗？list.stream().filter().foreach()

Answer 1

排序取决于源数据结构和中间流操作。假设您使用的是list，那么处理应该是有序的（因为filter在这里不会更改顺序）。

JavaDocs

S sequential()
Returns an equivalent stream that is sequential. May return itself, either because the stream was already sequential, or because the underlying stream state was modified to be sequential.
This is an intermediate operation.

S parallel()
Returns an equivalent stream that is parallel. May return itself, either because the stream was already parallel, or because the underlying stream state was modified to be parallel.
This is an intermediate operation.

S unordered()
Returns an equivalent stream that is unordered. May return itself, either because the stream was already unordered, or because the underlying stream state was modified to be unordered.
This is an intermediate operation.

JavaDocs

流可能具有定义的遇到顺序，也可能没有定义的遇到顺序。流是否有遇到顺序取决于源和中间操作。某些流源（如列表或数组）是内在有序的，而其他流源（如HashSet）则不是。一些中间操作（如sorted（））可能会对无序的流施加偶遇顺序，而其他操作可能会使有序的流无序化，如basestream.unordered（）。此外，一些终端操作可能忽略遇到顺序，例如forEach（）。

如果一个流是有序的,那么大多数操作都被限制为按它们遇到的顺序对元素进行操作；如果流的源是包含[1,2,3]的列表，那么执行html" target="_blank">map(x->x*2)的结果必须是[2,4,6]。但是，如果源没有定义的遇到顺序，那么值[2,4,6]的任何排列都将是有效的结果。

对于顺序流，有无遇到顺序不影响性能，只影响确定性。如果对一个流进行排序，那么在一个相同的源上重复执行相同的流管道将产生相同的结果；如果不对其进行排序，重复执行可能会产生不同的结果。

对于并行流，放松排序约束有时可以实现更高效的执行。如果元素的排序不相关，则可以更有效地实现某些聚合操作，例如筛选重复项（distinct（））或分组约简（Collectors.GroupingBy（））。类似地，在本质上绑定到遇到顺序的操作（如limit（））可能需要缓冲以确保正确的顺序，从而破坏了并行性的好处。在流有遇到顺序但用户并不特别关心遇到顺序的情况下，使用unordered（）显式地解除流的顺序可能会提高某些状态操作或终端操作的并行性能。然而，大多数流管道，例如上面的“块权重之和”示例，即使在排序约束下仍然高效地并行化。

Answer 2

你问错了问题。您询问的是sequential与parallel之间的关系，而您希望按顺序处理项目，因此必须询问排序问题。如果您有一个有序流,并且执行了保证维持该顺序的操作,那么该流是并行处理还是顺序处理都无关紧要；执行将维持秩序。

ordered属性不同于parallel和Sequential。例如。如果对哈希集调用stream()，则在对列表调用stream()返回有序流时，流将是无序的。请注意，您可以调用unordered()来释放订购合同并潜在地提高性能。一旦流没有排序，就无法重新建立排序。（将无序流转换为有序流的唯一方法是调用sorted，但是，得到的顺序不一定是原始顺序）。

另请参阅java.util.Stream包文档的“Ordering”部分。

为了确保在整个流操作中维护订单，您必须研究流的源、所有中间操作和终端操作的文档，以确定它们是否维护订单（或者源首先是否有订单）。

这可能非常微妙，例如stream.iterate(T,UnaryOperator)创建有序流，而stream.generate(Supplier)创建无序流。请注意，您在问题中还犯了一个常见错误，因为foreach不维护顺序。如果要按照保证的顺序处理流的元素，则必须使用foreachordered。

因此，如果问题中的list确实是java.util.list，那么它的stream()方法将返回一个有序流，filter不会更改顺序。因此，如果调用List.Stream().filter().ForeachOrdered()，所有元素都将按顺序被处理，而对于List.ParallelStream().filter().ForeachOrdered()，元素可能被并行处理（例如，由筛选器处理），但终端操作仍将按顺序调用（这显然会降低并行执行的好处）。

例如，如果使用以下操作

List<…> result=inputList.parallelStream().map(…).filter(…).collect(Collectors.toList());

整个操作可能会从并行执行中受益，但无论使用并行流还是顺序流，结果列表的顺序都是正确的。