ViewVC Help

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

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

Comparing jsr166/src/main/java/util/concurrent/ForkJoinWorkerThread.java (file contents):
Revision 1.22 by jsr166, Wed Sep 1 20:12:39 2010 UTC vs.
Revision 1.23 by jsr166, Wed Sep 1 20:15:43 2010 UTC

#	Line 478 | Line 478 | public class ForkJoinWorkerThread extend
478		*/
479		private void execLocalTasks() {
480		while (runState == 0) {
481	<	ForkJoinTask<?> t = locallyFifo? locallyDeqTask() : popTask();
481	>	ForkJoinTask<?> t = locallyFifo ? locallyDeqTask() : popTask();
482		if (t != null)
483		t.quietlyExec();
484		else if (sp == base)
#	Line 898 | Line 898 | public class ForkJoinWorkerThread extend
898		if (active ||
899		(active = UNSAFE.compareAndSwapInt(p, poolRunStateOffset,
900		a = p.runState, a + 1)))
901	<	return locallyFifo? locallyDeqTask() : popTask();
901	>	return locallyFifo ? locallyDeqTask() : popTask();
902		}
903		return null;
904		}

Diff Legend

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