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.42 by dl, Sun Aug 29 23:34:46 2010 UTC vs.
Revision 1.43 by jsr166, Wed Sep 1 20:12:39 2010 UTC

#	Line 381 | Line 381 | public class ForkJoinWorkerThread extend
381		if (active) {
382		int a; // inline p.tryDecrementActiveCount
383		active = false;
384	<	do {} while(!UNSAFE.compareAndSwapInt
385	<	(p, poolRunStateOffset, a = p.runState, a - 1));
384	>	do {} while (!UNSAFE.compareAndSwapInt
385	>	(p, poolRunStateOffset, a = p.runState, a - 1));
386		}
387		cancelTasks();
388		setTerminated();
#	Line 1126 | Line 1126 | public class ForkJoinWorkerThread extend
1126		}
1127		if (p.isQuiescent()) {
1128		active = true; // re-activate
1129	<	do {} while(!UNSAFE.compareAndSwapInt
1130	<	(p, poolRunStateOffset, a = p.runState, a+1));
1129	>	do {} while (!UNSAFE.compareAndSwapInt
1130	>	(p, poolRunStateOffset, a = p.runState, a+1));
1131		return;
1132		}
1133		}

Diff Legend

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