Searched refs:ws (Results 1 – 4 of 4) sorted by relevance
1515 WorkQueue[] ws = new WorkQueue[n]; in tryInitialize() local1518 workQueues = ws; in tryInitialize()1598 WorkQueue[] ws = workQueues; in registerWorker() local1599 if (ws != null && (n = ws.length) > 0) { in registerWorker()1601 if (ws[i] != null) { // collision in registerWorker()1604 while (ws[i = (i + step) & m] != null) { in registerWorker()1606 workQueues = ws = Arrays.copyOf(ws, n <<= 1); in registerWorker()1615 ws[i] = w; in registerWorker()1637 AuxState aux; WorkQueue[] ws; // remove index from array in deregisterWorker() local1643 if ((ws = workQueues) != null && ws.length > idx && in deregisterWorker()[all …]
210 int ws = node.waitStatus; in unparkSuccessor() local211 if (ws < 0) in unparkSuccessor()212 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()251 int ws = h.waitStatus; in doReleaseShared() local252 if (ws == Node.SIGNAL) { in doReleaseShared()257 else if (ws == 0 && in doReleaseShared()336 int ws; in cancelAcquire() local338 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()339 (ws <= 0 && pred.compareAndSetWaitStatus(ws, Node.SIGNAL))) && in cancelAcquire()362 int ws = pred.waitStatus; in shouldParkAfterFailedAcquire() local[all …]
676 int ws = node.waitStatus; in unparkSuccessor() local677 if (ws < 0) in unparkSuccessor()678 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()717 int ws = h.waitStatus; in doReleaseShared() local718 if (ws == Node.SIGNAL) { in doReleaseShared()723 else if (ws == 0 && in doReleaseShared()802 int ws; in cancelAcquire() local804 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()805 (ws <= 0 && pred.compareAndSetWaitStatus(ws, Node.SIGNAL))) && in cancelAcquire()828 int ws = pred.waitStatus; in shouldParkAfterFailedAcquire() local[all …]
383 long ws = lock.tryWriteLock(); in testWriteTryLockWhenLocked()384 assertTrue(ws == 0L); in testWriteTryLockWhenLocked()467 long ws = lock.writeLock(); in testWriteAfterMultipleReadLocks()468 lock.unlockWrite(ws); in testWriteAfterMultipleReadLocks()524 long ws = lock.tryWriteLock(); in testWriteTryLockWhenReadLocked()525 threadAssertEquals(ws, 0L); in testWriteTryLockWhenReadLocked()542 long ws = lock.tryWriteLock(timeoutMillis, MILLISECONDS); in testWriteTryLock_Timeout()543 assertEquals(ws, 0L); in testWriteTryLock_Timeout()