在Java8中parallelStream中生成了多少线程？

Question

在JDK8中，当我使用ParallelStream时会生成多少线程？例如，在代码中：

list.parallelStream().forEach(/** Do Something */);

如果这个列表有100000个项目，那么会产生多少个线程？

另外，是每个线程都得到相同数量的项目来工作，还是随机分配？

Answer 1

Oracle的并行流实现[1]使用当前线程，此外，如果需要，还使用组成默认fork连接池forkjoinpool.commonpool()的线程，该池的默认大小等于比CPU的内核数少一个。

可以使用以下属性更改公共池默认大小：

-Djava.util.concurrent.ForkJoinPool.common.parallelism=8

或者，您可以使用自己的池：

ForkJoinPool myPool = new ForkJoinPool(8);
myPool.submit(() ->
    list.parallelStream().forEach(/* Do Something */);
).get();

关于顺序，只要有一个线程可用，就会立即执行作业，没有特定的顺序。

正如@Holger所正确指出的，这是一个特定于实现的细节（在文档底部仅有一个模糊的引用），这两种方法都可以在Oracle的JVM上工作，但肯定不能保证在其他供应商的JVM上工作，该属性不可能存在于非Oracle实现中，流甚至不能在内部使用forkjoinpool使基于forkjoinask.fork行为的替代方案完全无用（请参阅此处了解有关此方面的详细信息）。