Searched refs:ws (Results 1 – 3 of 3) sorted by relevance
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ForkJoinPool.java | 1329 UncaughtExceptionHandler handler; WorkQueue[] ws; int s, ps; in registerWorker() local
1342 if ((ws = workQueues) != null) { // skip if shutting down in registerWorker()
1343 int n = ws.length, m = n - 1; in registerWorker()
1345 if (ws[r &= m] != null) { // collision in registerWorker()
1348 while (ws[r = (r + step) & m] != null) { in registerWorker()
1350 workQueues = ws = Arrays.copyOf(ws, n <<= 1); in registerWorker()
1358 ws[r] = w; in registerWorker()
1391 WorkQueue[] ws = workQueues; in deregisterWorker() local
1392 if (ws != null && idx >= 0 && idx < ws.length && ws[idx] == w) in deregisterWorker()
1393 ws[idx] = null; in deregisterWorker()
[all …]
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedSynchronizer.java | 623 int ws = node.waitStatus; in unparkSuccessor() local
624 if (ws < 0) in unparkSuccessor()
625 compareAndSetWaitStatus(node, ws, 0); in unparkSuccessor()
664 int ws = h.waitStatus; in doReleaseShared() local
665 if (ws == Node.SIGNAL) { in doReleaseShared()
670 else if (ws == 0 && in doReleaseShared()
747 int ws; in cancelAcquire() local
749 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()
750 (ws <= 0 && compareAndSetWaitStatus(pred, ws, Node.SIGNAL))) && in cancelAcquire()
773 int ws = pred.waitStatus; in shouldParkAfterFailedAcquire() local
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 393 int ws = node.waitStatus; in unparkSuccessor() local
394 if (ws < 0) in unparkSuccessor()
395 compareAndSetWaitStatus(node, ws, 0); in unparkSuccessor()
434 int ws = h.waitStatus; in doReleaseShared() local
435 if (ws == Node.SIGNAL) { in doReleaseShared()
440 else if (ws == 0 && in doReleaseShared()
517 int ws; in cancelAcquire() local
519 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()
520 (ws <= 0 && compareAndSetWaitStatus(pred, ws, Node.SIGNAL))) && in cancelAcquire()
543 int ws = pred.waitStatus; in shouldParkAfterFailedAcquire() local
[all …]
|