流处理线程池耗尽

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();

它只需记住您的池，并在池中启动终端操作，加入结果。只是前面提到的解决方案的语法糖。