如何确保java8流中的处理顺序?
我想处理XMLJava
对象中的列表。我必须确保处理所有元素,以便收到它们。
因此sequentia
l,stream
我应该使用它吗? list.stream().sequential().filter().forEach()
还是只要不使用并行性就足以使用流? list.stream().filter().forEach()
回答:
你在问错问题。你正在询问sequentialvs. parallel
而要按顺序处理项目,因此你必须询问订购。如果你有顺序的流并执行保证维持顺序的操作,则该流是并行处理还是顺序处理都没有关系;实施将维持秩序。
有序属性不同于并行与顺序。例如,如果你调用stream()
一个HashSet
同时调用流将是无序stream()
在List返回的有序流。请注意,你可以致电unordered()
以解除订购合同并可能提高性能。一旦流没有排序,就无法重新建立排序。(将无序流变成有序流的唯一方法是调用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());
整个操作可能会受益于并行执行,但是无论你使用并行流还是顺序流,结果列表始终会以正确的顺序排列。
以上是 如何确保java8流中的处理顺序? 的全部内容, 来源链接: utcz.com/qa/432609.html