为什么stream parallel（）不使用所有可用的线程？

Question

java prettyprint-override">    @Test
    public void testParallelStream() throws Exception {
        final int REQUESTS = 100;
        ForkJoinPool forkJoinPool = null;
        try {
            // new ForkJoinPool(256): same results for all tried values of REQUESTS
            forkJoinPool = new ForkJoinPool(REQUESTS);
            forkJoinPool.submit(() -> {

                IntStream stream = IntStream.range(0, REQUESTS);
                final List<String> result = stream.parallel().mapToObj(i -> {
                    try {
                        System.out.println("request " + i);
                        Thread.sleep(1000);
                        return Integer.toString(i);
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }).collect(Collectors.toList());
                // assertThat(result).hasSize(REQUESTS);
            }).join();
        } finally {
            if (forkJoinPool != null) {
                forkJoinPool.shutdown();
            }
        }
    }

output指示在1s暂停之前执行16个流元素，然后再执行16个元素，依此类推。因此，即使forkjoinpool是用100个线程创建的，也只有16个线程被使用。

当我使用超过23个线程时，就会出现这种模式：

1-23 threads: ~1s
24-35 threads: ~2s
36-48 threads: ~3s
...

System.out.println(Runtime.getRuntime().availableProcessors());
// Output: 4

Answer 1

由于流实现对fork/join池的使用是一个实现细节，迫使它使用不同的fork/join池的技巧也没有文档化，而且似乎是偶然的，即有一个硬编码的常量决定实际的并行度，这取决于默认池的并行度。所以最初并没有预见到使用不同的池。

但是，已经认识到使用具有不适当的目标并行性的不同池是一个bug，即使这个把戏没有文档化，请参见JDK-8190974。

它已经在Java ；10中被修复，并被备份到Java ；8，update ；222。

因此，一个简单的解决方案世界正在更新Java版本。

您还可以更改默认池的并行性，例如。

System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "100");

在执行任何fork/join活动之前。