--- jsr166/src/jsr166y/CountedCompleter.java 2012/10/21 05:28:08 1.5 +++ jsr166/src/jsr166y/CountedCompleter.java 2012/11/14 20:06:49 1.12 @@ -142,7 +142,7 @@ package jsr166y; * * As a further improvement, notice that the left task need not even * exist. Instead of creating a new one, we can iterate using the - * original task, and add a pending count for each fork: + * original task, and add a pending count for each fork. * *
{@code * class ForEach... @@ -378,6 +378,19 @@ public abstract class CountedCompleter getRoot() { + CountedCompleter> a = this, p; + while ((p = a.completer) != null) + a = p; + return a; + } + + /** * If the pending count is nonzero, decrements the count; * otherwise invokes {@link #onCompletion} and then similarly * tries to complete this task's completer, if one exists, @@ -465,7 +478,6 @@ public abstract class CountedCompleter