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

Question

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

因此sequential，stream我应该使用它吗？ list.stream().sequential().filter().forEach()

还是只要不使用并行性就足以使用流？ list.stream().filter().forEach()

Answer 1

你在问错问题。你正在询问sequentialvs. parallel而要按顺序处理项目，因此你必须询问订购。如果你有顺序的流并执行保证维持顺序的操作，则该流是并行处理还是顺序处理都没有关系；实施将维持秩序。

有序属性不同于并行与顺序。例如，如果你调用stream()一个HashSet同时调用流将是无序stream()在List返回的有序流。请注意，你可以致电unordered()以解除订购合同并可能提html" target="_blank">高性能。一旦流没有排序，就无法重新建立排序。（将无序流变成有序流的唯一方法是调用sorted，但是，生成的顺序不一定是原始顺序）。

又见“订购”一节中的java.util.stream包文档。

为了确保在整个流操作中维持顺序，你必须研究流源，所有中间操作和终端操作的文档，以了解它们是否维持顺序（或者源是否在第一顺序中具有顺序）地点）。

这可能非常微妙，例如，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());

整个操作可能会受益于并行执行，但是无论你使用并行流还是顺序流，结果列表始终会以正确的顺序排列。