Java8流中的并行性和Flatmap

Question

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

result.sequential().forEach(downstream);

Answer 1

在当前的JDK(JDK1.8.0_25)中，答案是否定的，将inner标志设置为parallel并不重要，因为即使设置了它，.flatMap（）实现也将流设置为sequential：

result.sequential().forEach(downstream);

（“result”是内部流，它的sequential（）方法的doc说：返回一个等价的序列流。可能返回它自己，可能是因为该流已经是序列的，也可能是因为底层流状态被修改为序列的。）

在大多数情况下，不可能努力使内河平行；如果外部流的项目数至少与可以并行运行的线程数相同(ForkJoinPool.CommonPool().GetParallelism()=3)。