分叉连接池吊架

Question

情况是应用程序不时地无限挂起。

ForkJoinPool pool = new ForkJoinPool(1); // parallelism = 1

List<String> entries = ...;

pool.submit(() -> {

    entries.stream().parallel().forEach(entry -> {
        // An I/O op.
        ...
    });

}).get();

执行代码的线程池-4-线程-1在get()上冻结：

"pool-4-thread-1" #35 prio=5 os_prio=0 tid=0x00002b42e4013800 nid=0xb7d1 in Object.wait() [0x00002b427b72f000]
       java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        at java.util.concurrent.ForkJoinTask.externalInterruptibleAwaitDone(ForkJoinTask.java:367)
        - locked <0x00000000e08b68b8> (a java.util.concurrent.ForkJoinTask$AdaptedRunnableAction)
        at java.util.concurrent.ForkJoinTask.get(ForkJoinTask.java:1001)
...other app methods

可以假设传递给submit()的任务执行时间过长。

但令人惊讶的是，线程转储中没有forkjoinpool-n-worker-n出现，因此看起来池没有执行任何计算！

Answer 1

设置Parallelism=n，其中n>1解决了问题。

奇怪的事情，但在forkjoinpool中似乎存在一些类似于这里所述的bug。