Home
last modified time | relevance | path

Searched refs:ws (Results 1 – 5 of 5) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinPool.java1518 WorkQueue[] ws = new WorkQueue[n]; in tryInitialize() local
1521 workQueues = ws; in tryInitialize()
1601 WorkQueue[] ws = workQueues; in registerWorker() local
1602 if (ws != null && (n = ws.length) > 0) { in registerWorker()
1604 if (ws[i] != null) { // collision in registerWorker()
1607 while (ws[i = (i + step) & m] != null) { in registerWorker()
1609 workQueues = ws = Arrays.copyOf(ws, n <<= 1); in registerWorker()
1618 ws[i] = w; in registerWorker()
1640 AuxState aux; WorkQueue[] ws; // remove index from array in deregisterWorker() local
1646 if ((ws = workQueues) != null && ws.length > idx && in deregisterWorker()
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedLongSynchronizer.java210 int ws = node.waitStatus; in unparkSuccessor() local
211 if (ws < 0) in unparkSuccessor()
212 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()
251 int ws = h.waitStatus; in doReleaseShared() local
252 if (ws == Node.SIGNAL) { in doReleaseShared()
257 else if (ws == 0 && in doReleaseShared()
336 int ws; in cancelAcquire() local
338 ((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 …]
DAbstractQueuedSynchronizer.java676 int ws = node.waitStatus; in unparkSuccessor() local
677 if (ws < 0) in unparkSuccessor()
678 node.compareAndSetWaitStatus(ws, 0); in unparkSuccessor()
717 int ws = h.waitStatus; in doReleaseShared() local
718 if (ws == Node.SIGNAL) { in doReleaseShared()
723 else if (ws == 0 && in doReleaseShared()
802 int ws; in cancelAcquire() local
804 ((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 …]
/libcore/jsr166-tests/src/test/java/jsr166/
DStampedLockTest.java383 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()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DStampedLockTest.java547 long ws = lock.writeLock(); in testWriteAfterMultipleReadLocks()
548 lock.unlockWrite(ws); in testWriteAfterMultipleReadLocks()