ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/jsr166y/ForkJoinPool.java
(Generate patch)

Comparing jsr166/src/jsr166y/ForkJoinPool.java (file contents):
Revision 1.91 by dl, Tue Feb 22 00:39:31 2011 UTC vs.
Revision 1.92 by dl, Tue Feb 22 10:50:51 2011 UTC

# Line 771 | Line 771 | public class ForkJoinPool extends Abstra
771              long d = ctl; // return true if lost to a deq, to force rescan
772              return (int)d != (int)c && ((d - c) & AC_MASK) >= 0L;
773          }
774 +        if (parallelism + (int)(c >> AC_SHIFT) == 1 &&
775 +            blockedCount == 0 && quiescerCount == 0)
776 +            idleAwaitWork(w, v);               // quiescent -- maybe shrink
777 +
778          boolean rescanned = false;
779          for (int sc;;) {
780              if (w.eventCount != v)
# Line 804 | Line 808 | public class ForkJoinPool extends Abstra
808                  else
809                      Thread.interrupted();          // clear before park
810              }
807 –            else if (parallelism + (int)(ctl >> AC_SHIFT) == 0 &&
808 –                     blockedCount == 0 && quiescerCount == 0)
809 –                idleAwaitWork(w, v);               // quiescent -- maybe shrink
811              else {
812                  w.parked = true;                   // must recheck
813                  if (w.eventCount != v) {

Diff Legend

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