平行流如何“知道”使用封闭的ForkJoinpool？

Question

在Java8中，可以设置一个自定义forkJoinpool，由并行流而不是公共池使用。

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

我的问题是技术上是如何发生的
流在任何方面都不知道它已提交到自定义forkJoinpool，并且无法直接访问它。那么，最终如何使用正确的线程来处理流的任务呢？

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

谢谢！

Answer 1

java。util。流动前肢手术。ForEachOp#evaluateParallel方法调用invoke（）：

@Override
public <S> Void evaluateParallel(PipelineHelper<T> helper,
                                 Spliterator<S> spliterator) {
    if (ordered)
        new ForEachOrderedTask<>(helper, spliterator, this).invoke();
    else
        new ForEachTask<>(helper, spliterator, helper.wrapSink(this)).invoke();
    return null;
}

它依次调用java。util。同时发生的ForkJoinTask#doInvoke：

private int doInvoke() {
    int s; Thread t; ForkJoinWorkerThread wt;
    return (s = doExec()) < 0 ? s :
        ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) ?
        (wt = (ForkJoinWorkerThread)t).pool.
        awaitJoin(wt.workQueue, this, 0L) :
        externalAwaitDone();
}

如上面的方法所示，它使用thread查找当前线程。currentThread（）。

然后使用。池字段，如（wt=（ForkJoinWorkerThread）t中所示。池，它提供此线程运行的当前池：

public class ForkJoinWorkerThread extends Thread {

    final ForkJoinPool pool;                // the pool this thread works in

Answer 2

从我所读的代码中，决策仅基于触发计算的初始线程，在方法ForkJoinTask::fok中，从字面上对触发此的线程进行检查（也在其留档中）：

Thread.currentThread()) instanceof ForkJoinWorkerThread

因此，如果ForkJoinWorkerThread的一个实例启动了此任务（这是通过自定义ForkJoinPool可以得到的），请使用该池中已经存在且该任务在其中运行的任何资源；否则（如果它是一个不同的线程，而不是ForkJoinWorkerThread的实例），请使用：

ForkJoinPool.common.externalPush(this); 

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