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.26 by dl, Sun Aug 2 11:54:31 2009 UTC vs.
Revision 1.27 by dl, Mon Aug 3 13:01:15 2009 UTC

#	Line 383 | Line 383 | public class ForkJoinWorkerThread extend
383		*/
384		protected void onTermination(Throwable exception) {
385		// Execute remaining local tasks unless aborting or terminating
386	<	while (exception == null &&  !pool.isTerminating() && base != sp) {
386	>	while (exception == null && pool.isProcessingTasks() && base != sp) {
387		try {
388		ForkJoinTask<?> t = popTask();
389		if (t != null)

Diff Legend

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