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.316 by dl, Wed Jun 8 19:44:32 2016 UTC vs.
Revision 1.317 by dl, Fri Jun 17 13:03:45 2016 UTC

# Line 1384 | Line 1384 | public class ForkJoinPool extends Abstra
1384          }
1385          if (phase != QUIET) {                         // else pre-adjusted
1386              long c;                                   // decrement counts
1387 <            do {} while (!CTL.compareAndSet
1387 >            do {} while (!CTL.weakCompareAndSetVolatile
1388                           (this, c = ctl, ((RC_MASK & (c - RC_UNIT)) |
1389                                            (TC_MASK & (c - TC_UNIT)) |
1390                                            (SP_MASK & c))));
# Line 1579 | Line 1579 | public class ForkJoinPool extends Abstra
1579                      do {
1580                          w.stackPred = (int)(c = ctl);
1581                          nc = ((c - RC_UNIT) & UC_MASK) | (SP_MASK & np);
1582 <                    } while (!CTL.compareAndSet(this, c, nc));
1582 >                    } while (!CTL.weakCompareAndSetVolatile(this, c, nc));
1583                  }
1584                  else {                                  // already queued
1585                      int pred = w.stackPred;

Diff Legend

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