java - Java 8 Streams 中的并行性和平面图

Question

考虑以下示例:

    IntStream.of(-1, 1)
             .parallel()
             .flatMap(i->IntStream.range(0,1000).parallel())
             .forEach(System.out::println);

是否将内部标志设置为平行有关系吗？无论是否保留，结果看起来都非常相似。

另外，为什么代码 (ReferencePipeline) 对映射进行顺序化？

我对 line 感到困惑:

result.sequential().forEach(downstream);

Answer 1

在目前的JDK(jdk1.8.0_25)中，答案是否定的，你把inner flag设置为parallel也没关系，因为即使你设置了它，.flatMap () 实现集将流返回到此处的顺序:

result.sequential().forEach(downstream);

("result"是内部流，它是 sequential() 方法的文档说:返回一个等效的顺序流。 可能会返回自己，因为流已经是顺序的，或者因为底层流状态被修改为顺序的。)

在大多数情况下，可以不努力使内部流平行；如果外部流的项数至少与可以并行运行的线程数相同(ForkJoinPool.commonPool().getParallelism() = 3 在我的计算机中)。