parallel-processing - 流处理线程池耗尽

Question

我发现 JVM 只有一个线程池用于并行处理流，这很困难。我们在一个大流上有一个 I/O 阻塞函数，它导致与不相关并行流一起使用的不相关或快速函数的活跃度问题。

stream 上没有允许使用备用线程池的方法。

有没有一种简单的方法可以避免这个问题，或许可以指定使用哪个线程池？

Answer 1

我写了一个叫做 StreamEx 的小库可以向自定义 FJP 提交任务。所以你可以写

ForkJoinPool forkJoinPool = new ForkJoinPool(2);
int[] primes = IntStreamEx.range(1, 1_000_000)
    .parallel(forkJoinPool)
    .filter(PrimesPrint::isPrime).toArray();

它只是记住您的池并在其中启动终端操作以加入结果。只是上述解决方案的语法糖。