ForkJoinPool.commonPool()和新ForkJoinPool(availableCPU - 1)有什么区别？

Question

在我的代码中，我有一个包含静态最终变量的类。

private static final ForkJoinPool pool = new ForkJoinPool(availableCPUs - 1);

我有一个长期运行的任务提交到池，这将占用所有的CPU资源。提交的任何其他任务都将被挂起。但是，当我切换到创建一个公共池时

private static final ForkJoinPool pool = ForkJoinPool.commonPool();

所有的任务都可以提交和执行。

我只是想知道这两段代码之间有什么区别。commonPool()仍然调用new ForkJoinPool()并传递availableCPUs - 1

我还注意到，commonPool()使用SafeForkJoinWorkerThreadFactory类型的工厂，而new ForkJoinPool()使用ForkJoinPool$DefaultForkJoinWorkerThreadFactory。这有关系吗？

非常感谢!

Answer 1

我想我想明白了。

ForkJoin维护两种类型的队列:一个普通入站队列和每个工作线程的工作线程队列。所有工作线程将首先从一般入站队列中获取并填充它们的辅助线程。在一个辅助线程完成其辅助队列中的所有任务后，它将尝试从其他辅助线程中窃取。如果没有其他任务要从其他工作线程窃取，则工作线程将再次从普通入站队列中获取。

但是，对于公共池，主线程也将帮助处理任务。但是主线程没有工作队列。因此，完成一个任务后，主线程将能够从一般入站队列中获取。

由于默认情况下，ForkJoin队列是LIFO，主线程将能够获取最后提交的任务。

Answer 2

文档说：

默认情况下，公共池是用默认参数构造的。ForkJoinPool() 使用ForkJoinPool、无UncaughtExceptionHandler和非异步LIFO处理模式创建并行性等于Runtime.availableProcessors()的默认线程工厂。

那么，是什么使您认为new ForkJoinPool(availableCPUs - 1)和ForkJoinPool.commonPool()将是相同大小的池呢？

如果您只有2个CPU，那么availableCPUs - 1就意味着您正在创建一个由1个线程组成的池，也就是说，它一次只能处理一个任务，因此一个长期运行的任务将阻塞所有其他任务。

但是使用两个CPU，availableProcessors()意味着您将得到一个具有两个线程的公共池，也就是说，它可以在处理单个长期运行的任务时处理其他任务。