ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/main/java/util/concurrent/CountedCompleter.java

Comparing jsr166/src/main/java/util/concurrent/CountedCompleter.java (file contents):
Revision 1.67 by dl, Fri Jan 17 18:12:07 2020 UTC vs.
Revision 1.68 by dl, Mon Jan 20 15:51:54 2020 UTC

#	Line 706 | Line 706 | public abstract class CountedCompleter<T
706		// ForkJoinTask overrides
707
708		/**
709	–	* Specialized helping for awaitJoin
710	–	*/
711	–	@Override
712	–	final int awaitJoin(boolean interruptible, boolean ran) {
713	–	Thread t; ForkJoinWorkerThread wt;
714	–	ForkJoinPool p; ForkJoinPool.WorkQueue q; int s;
715	–	if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) {
716	–	p = (wt = (ForkJoinWorkerThread)t).pool;
717	–	q = wt.workQueue;
718	–	}
719	–	else {
720	–	p = ForkJoinPool.common;
721	–	q = ForkJoinPool.commonQueue();
722	–	}
723	–	return ((s = (p == null ? 0 : p.helpComplete(this, q))) < 0 ? s :
724	–	awaitDone(interruptible, 0L, (s == ADJUST) ? p : null));
725	–	}
726	–
727	–	/**
709		* Supports ForkJoinTask exception propagation.
710		*/
711		@Override

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines