ViewVC Help

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

root/jsr166/jsr166/src/jsr166y/ForkJoinWorkerThread.java

Comparing jsr166/src/jsr166y/ForkJoinWorkerThread.java (file contents):
Revision 1.43 by jsr166, Wed Sep 1 20:12:39 2010 UTC vs.
Revision 1.44 by jsr166, Wed Sep 1 20:15:43 2010 UTC

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

Diff Legend

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