# | Line 429 | Line 429 | public abstract class CountedCompleter<T | |
---|---|---|
429 | } | |
430 | } | |
431 | else if (U.compareAndSwapInt(a, PENDING, c, c - 1)) { | |
432 | < | if (!(Thread.currentThread() instanceof ForkJoinWorkerThread)) |
432 | > | if (!(Thread.currentThread() instanceof ForkJoinWorkerThread)) |
433 | ForkJoinPool.popAndExecCCFromCommonPool(a); | |
434 | return; | |
435 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |