ForkJoinPool调度与ExecutorService

Question

我对ExecutorService和ForkJoinpool的内部调度机制有点困惑。

同时，forkjoinpool显示为不同的，因为它使用了工作窃取算法。如果我理解正确，它意味着一个线程可以从另一个线程窃取一些任务。

然而，我并不真正理解ExecutorService和ForkJoinpool中实现的机制之间的区别。从我的理解来看，两种机制都应该尽可能减少每个线程的空闲时间。

如果在ExecutorService的情况下，每个线程都有自己的队列，我会理解的。然而，情况并非如此，因为队列是由池的不同线程共享的。

Answer 1

假设您有一个非常大的ints数组，并且您希望将它们全部相加。对于ExecutorService，您可以说：让我们将该数组划分为线程数/4的块。因此，如果您有一个160个元素的数组（并且有4个CPU)，则创建160/4/4=10，因此您将创建16个块，每个块包含10个ints。创建Runnables/Callables并将其提交给executor服务（当然，一旦这些结果完成，请考虑合并这些结果的方法）。

现在，您的希望是每个CPU将承担其中的4个任务并对其进行工作。现在让我们也假设一些数字添加起来非常复杂（当然不是，但请原谅我），结果可能是3个线程/CPU完成了它们的工作，而其中一个只忙于第一个块。当然，没有人希望这样，但可能会发生。现在不好的是你对此无能为力。

相反，forkjoinpool所做的是，为我提供如何拆分任务和实现，以减少我必须做的最小工作量，其余的由我来处理。在流API中，这是用拆分器完成的；主要有两个方法trysplit（返回null，这意味着什么都不能拆分，或者返回一个新的spliterator，这意味着一个新的块）和foreachremaning，一旦不能拆分任务，它将处理元素。这就是偷工作会帮助你的地方。

你说你的块是如何计算的（通常是一分为二），以及当你不能再分裂时该怎么办。ForkJoinpool将把第一个块分派给所有线程，当其中一些线程空闲时--它们完成了工作，它们可以从其他线程查询其他队列，看看它们是否有工作。如果他们注意到其他一些线程队列中有块，他们将接收它们，单独拆分它们并处理它们。它甚至可以证明，它们自己并不完成对这些块的全部工作--其他一些线程现在可以查询该线程的队列，并注意到还有工作要做，等等...这比现在好得多，当这3个线程空闲时，他们可以拿起一些其他的工作来做--而且所有的线程都很忙。

这个例子有点简化，但离现实并不太远。只是您需要比CPU的/线程多得多的块来工作窃取；因此，通常trysplit必须有一个聪明的实现，并且在流的源中需要很多元素。