如何配置单线程ForkJoinPool？

Question

是否可以配置ForkJoinpool使用1个执行线程？

我正在执行在ForkJoinPool中调用Random的代码。每次它运行时，我都会遇到不同的运行时行为，这使得研究回归变得很困难。

我希望代码库提供“调试”和“发布”模式。“调试”模式将使用固定种子配置Random，并使用单个执行线程配置ForkJoinPool。“释放”模式将使用系统提供的Random种子，并使用默认数量的ForkJoinPool线程。

我尝试配置ForkJoinpool的并行性为1，但它使用2个线程（main和第二个工作线程）。有什么想法吗？

Answer 1

主线程始终是应用程序将创建的第一个线程。因此，当您创建具有1的并行性的ForkJoinpool时，您正在创建另一个线程。实际上，应用程序中现在将有两个线程（因为您创建了线程的池）。

如果您只需要一个主线程，您可以按顺序执行代码（而不是并行执行）。

Answer 2

所以，结果证明我错了。

当您配置将并行性设置为1的ForkJoinpool时，只有一个线程执行任务。主线程在ForkJoin.get（）上被阻塞。它实际上不执行任何任务。

也就是说，事实证明，提供确定性行为确实很棘手。以下是我必须纠正的一些问题：

• ForkJoinpool如果工作线程空闲足够长，则使用不同的工作线程（具有不同的名称）执行任务。例如，如果主线程在调试断点上挂起，则工作线程将变为空闲并关闭。当我要恢复执行时，ForkJoinThread将旋转一个新的工作线程，其名称不同。为了解决这个问题，我必须提供一个自定义的ForkJoinWorkerThreadFactory实现，如果ForkJoinpool已经有一个活动的工作人员（这防止池创建多个工作人员），则返回null。我还必须确保我的代码返回相同的Random实例，即使一个工作线程关闭并再次返回。
• 具有非确定性迭代顺序（如HashMap或HashSet）的集合导致元素在每次运行时以不同的顺序抓取随机数。我通过使用LinkedHashMap和LinkedHashSet纠正了这一点。
• 具有非确定性hashCode（）实现的对象，例如Enum.hashCode（）。我忘记了这导致了什么问题，但我通过自己计算hashCode（）来纠正它，而不是依赖于内置的方法。

以下是ForkJoinWorkerThreadFactory的示例实现：

class MyForkJoinWorkerThread extends ForkJoinWorkerThread
{
    MyForkJoinWorkerThread(ForkJoinPool pool)
    {
        super(pool);
        // Change thread name after ForkJoinPool.registerWorker() does the same
        setName("DETERMINISTIC_WORKER");
    }
}

ForkJoinWorkerThreadFactory factory = new ForkJoinWorkerThreadFactory()
{
    private WeakReference<Thread> currentWorker = new WeakReference<>(null);

    @Override
    public synchronized ForkJoinWorkerThread newThread(ForkJoinPool pool)
    {
        // If the pool already has a live thread, wait for it to shut down.
        Thread thread = currentWorker.get();
        if (thread != null && thread.isAlive())
        {
            try
            {
                thread.join();
            }
            catch (InterruptedException e)
            {
                log.error("", e);
            }
        }
        ForkJoinWorkerThread result = new MyForkJoinWorkerThread(pool);
        currentWorker = new WeakReference<>(result);
        return result;
    }
};