3

这是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;
    }
}

这让我真的很困惑。文档说：“然后类似地尝试完成这个任务的完成者”，但我没有看到在这个任务的完成者上调用任何“完成”；或任何其他调用它。

有人在这门课上工作过吗？这是文档或实施的问题吗？我也可能用错误的方式烹饪它。任何如何正确处理此类的想法都值得赞赏。

4

1 回答 1

9

你糊涂了？每个人都很困惑。四年来我一直在写一篇关于 F/J 框架的评论，我可以告诉你复杂程度已经达到了 8u40 的临界水平。这个类存在的原因是因为 join()不起作用。为了绕过 Java8 流的停滞线程，架构师发明了这个类。

你工作这个类的方式是你为每个 fork() 添加ToPendingCount()。在compute()中，完成后，你tryComplete()。当计数为零时，该方法会调用您的 onCompletion()。有点乱，但如果你的代码很简单，它就可以工作。

您看到的其余代码适用于当前 CountedCompleter 拥有自己的 CountedCompleter 对象链的情况。我的猜测是这可能是用于 parallel.stream 处理。

于 2015-04-30T14:40:32.770 回答