并行流如何“知道”使用封闭的ForkJoinPool？

Question

在Java8中，可以设置一个定制的forkJoinPool供并行流使用，而不是公共池。

forkJoinPool.submit(() -> list.parallelStream().forEach(x ->{...} ))

我的问题是它在技术上是如何发生的？
流以任何方式都不知道它被提交给了自定义的forkJoinpool并且没有直接访问它的权限。那么最终如何使用正确的线程来处理流的任务呢？

我试着看源代码，但没有用。我的最佳猜测是在提交时的某个点设置了某个threadLocal变量，然后在稍后由流使用。如果是这样的话，为什么语言开发人员会选择这样一种方式来实现行为，而不是将池注入流中的依赖关系呢？

Answer 1

根据我阅读的代码，决策仅基于触发计算的初始线程，方法ForkJointAsk::Fork中的线程，该方法实际上会检查触发计算的线程（也在其文档中）：

Thread.currentThread()) instanceof ForkJoinWorkerThread

因此，如果ForkJoinWorkerThread的一个实例启动了此操作（这是您将通过自定义的ForkJoinPool获得的），则使用已存在的池并在其中运行此任务；否则（如果是不是ForkJoinWorkerThread实例的其他线程），请使用：

ForkJoinPool.common.externalPush(this); 

同样有趣的是，ForkJoinWorkerThread实际上是一个Public类，因此您可以在它的实例中启动计算，但仍然使用不同的池；虽然我没有试过。