由CountedCompleter的文档和来源混淆

Question

这是java.util.concurrent.CountedCompleter类的代码片段(JDK 1.8.0_25).

/**
 * If the pending count is nonzero, decrements the count;
 * otherwise invokes {@link #onCompletion(CountedCompleter)}
 * and then similarly tries to complete this task's completer,
 * if one exists, else marks this task as complete.
 */
public final void tryComplete() {
    CountedCompleter<?> a = this, s = a;
    for (int c;;) {
        if ((c = a.pending) == 0) {
            a.onCompletion(s);
            if ((a = (s = a).completer) == null) {
                s.quietlyComplete();
                return;
            }
        }
        else if (U.compareAndSwapInt(a, PENDING, c, c - 1))
            return;
    }
}

这让我很困惑.文档说:"然后类似地尝试完成此任务的完成者",但我没有看到在此任务的完成者上有任何"完成"的调用; 或任何其他电话.

有人和这个班级一起工作过吗？这是文档或实现的问题吗？我也可能以错误的方式做饭.任何想法如何正确处理这个类是值得赞赏的.

Answer 1

你很困惑？每个人都很困惑.我已经对F/J框架进行了四年的批评,我可以告诉你复杂程度达到了8u40的临界水平.这个类存在的原因是因为join()不起作用.为了绕过Java8流的停滞线程,架构师发明了这个类.

你使用这个类的方法是为每个fork()添加addToPendingCount().在compute()中,完成后,尝试完成().当计数为零时,该方法调用onCompletion().有点乱,但如果你的代码很简单,那就行了.

您看到的其余代码适用于当前的CountedCompleter具有自己的一系列CountedCompleter对象.我的猜测是这可能是parallel.stream处理.