878 |
|
} |
879 |
|
} |
880 |
|
} |
881 |
< |
|
881 |
> |
|
882 |
|
/** |
883 |
|
* If present, removes from queue and executes the given task, |
884 |
|
* or any other cancelled task. Returns (true) on any CAS |
1386 |
|
if (wt != null && (w = wt.workQueue) != null) { |
1387 |
|
int ps; long sc; |
1388 |
|
w.qlock = -1; // ensure set |
1389 |
< |
do {} while(!U.compareAndSwapLong(this, STEALCOUNT, sc = stealCount, |
1390 |
< |
sc + w.nsteals)); |
1389 |
> |
do {} while (!U.compareAndSwapLong(this, STEALCOUNT, |
1390 |
> |
sc = stealCount, |
1391 |
> |
sc + w.nsteals)); |
1392 |
|
if (((ps = plock) & PL_LOCK) != 0 || |
1393 |
|
!U.compareAndSwapInt(this, PLOCK, ps, ps += PL_LOCK)) |
1394 |
|
ps = acquirePlock(); |
1734 |
|
else if ((ns = w.nsteals) != 0) { // collect steals and retry |
1735 |
|
long sc; |
1736 |
|
w.nsteals = 0; |
1737 |
< |
do {} while(!U.compareAndSwapLong(this, STEALCOUNT, |
1738 |
< |
sc = stealCount, sc + ns)); |
1737 |
> |
do {} while (!U.compareAndSwapLong(this, STEALCOUNT, |
1738 |
> |
sc = stealCount, sc + ns)); |
1739 |
|
} |
1740 |
|
else { |
1741 |
|
long pc = ((d > 0 || ec != (e | INT_SIGN)) ? 0L : |
3282 |
|
ForkJoinWorkerThreadFactory factory |
3283 |
|
= defaultForkJoinWorkerThreadFactory; |
3284 |
|
UncaughtExceptionHandler handler = null; |
3285 |
< |
try { // ignore exceptions in accesing/parsing properties |
3285 |
> |
try { // ignore exceptions in accessing/parsing properties |
3286 |
|
String pp = System.getProperty |
3287 |
|
("java.util.concurrent.ForkJoinPool.common.parallelism"); |
3288 |
|
String fp = System.getProperty |