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

Comparing jsr166/src/main/java/util/concurrent/ForkJoinPool.java (file contents):
Revision 1.206 by dl, Tue Jul 8 17:58:12 2014 UTC vs.
Revision 1.207 by dl, Tue Jul 8 19:09:41 2014 UTC

# Line 2161 | Line 2161 | public class ForkJoinPool extends Abstra
2161                  WorkQueue[] ws; WorkQueue w;      // check external submissions
2162                  if ((ws = workQueues) != null) {
2163                      for (int i = 0; i < ws.length; ++i) {
2164 <                        if ((w = ws[i]) != null && !w.isEmpty()) {
2164 >                        if ((w = ws[i]) != null &&
2165 >                            (!w.isEmpty() ||
2166 >                             ((i & 1) != 0 && w.scanState >= 0))) {
2167                              signalWork(ws, w);
2168                              return false;
2169                          }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines