Searched refs:ws (Results 1 – 4 of 4) sorted by relevance
1486 WorkQueue[] ws = new WorkQueue[n]; in tryInitialize() local1489 workQueues = ws; in tryInitialize()1569 WorkQueue[] ws = workQueues; in registerWorker() local1570 if (ws != null && (n = ws.length) > 0) { in registerWorker()1572 if (ws[i] != null) { // collision in registerWorker()1575 while (ws[i = (i + step) & m] != null) { in registerWorker()1577 workQueues = ws = Arrays.copyOf(ws, n <<= 1); in registerWorker()1586 ws[i] = w; in registerWorker()1608 AuxState aux; WorkQueue[] ws; // remove index from array in deregisterWorker() local1614 if ((ws = workQueues) != null && ws.length > idx && in deregisterWorker()[all …]
181 int ws = node.waitStatus; in unparkSuccessor() local182 if (ws < 0) in unparkSuccessor()183 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()222 int ws = h.waitStatus; in doReleaseShared() local223 if (ws == Node.SIGNAL) { in doReleaseShared()228 else if (ws == 0 && in doReleaseShared()307 int ws; in cancelAcquire() local309 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()310 (ws <= 0 && pred.compareAndSetWaitStatus(ws, Node.SIGNAL))) && in cancelAcquire()333 int ws = pred.waitStatus; in shouldParkAfterFailedAcquire() local[all …]
648 int ws = node.waitStatus; in unparkSuccessor() local649 if (ws < 0) in unparkSuccessor()650 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()689 int ws = h.waitStatus; in doReleaseShared() local690 if (ws == Node.SIGNAL) { in doReleaseShared()695 else if (ws == 0 && in doReleaseShared()774 int ws; in cancelAcquire() local776 ((ws = pred.waitStatus) == Node.SIGNAL || in cancelAcquire()777 (ws <= 0 && pred.compareAndSetWaitStatus(ws, Node.SIGNAL))) && in cancelAcquire()800 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()