ForkJoinPool似乎浪费了线程

Question

我正在比较测试程序上的两个变体。两者都ForkJoinPool在具有四个内核的计算机上以4线程运行。

在“模式1”下，我非常类似于执行程序服务来使用池。我把一堆任务扔了进去ExecutorService.invokeAll。与普通的固定线程执行器服务相比，我获得了更好的性能（即使有对Lucene的调用，该调用在其中执行了一些I
/ O）。

这里没有分而治之。从字面上看，我知道

ExecutorService es = new ForkJoinPool(4);
es.invokeAll(collection_of_Callables);

在“模式2”中，我向池提交一个任务，然后在该任务中调用ForkJoinTask.invokeAll提交子任务。因此，我有一个继承自的对象RecursiveAction，并将其提交到池中。在该类的计算方法中，我invokeAll从
另一个
类（也继承自）调用对象的集合RecursiveAction。出于测试目的，我一次只提交第一个对象。我天真地希望看到所有四个线程都忙，因为线程调用invokeAll将自己获取子任务之一，而不仅仅是坐着和阻塞。我可以想到某些原因导致它可能无法正常运行。

在模式2下的VisualVM中观看，几乎一个线程总是在等待。我希望看到的是，调用invokeAll的线程将立即在被调用的任务之一上工作，而不仅仅是停滞不前。这肯定比使用普通线程池尝试此方案所导致的死锁要好，但那又如何呢？它是否阻止了一个线程以防其他事情提交？而且，如果是这样，为什么在模式1下不会出现相同的问题？

到目前为止，我一直使用添加到Java 1.6的启动类路径中的jsr166 jar运行此程序。

Answer 1

ForkJoinTask.invokeAll正在分叉所有任务，但列表中的第一个。它自己运行的第一个任务。然后，它加入其他任务。它的线程不会以任何方式释放到池中。因此，您所看到的就是要完成其他任务的线程阻塞。