Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/java/util/concurrent/
DExchanger.java378 for (int h = p.hash, spins = SPINS;;) { in arenaExchange()
386 else if (spins > 0) { in arenaExchange()
391 (--spins & ((SPINS >>> 1) - 1)) == 0) in arenaExchange()
395 spins = SPINS; // releaser hasn't set match yet in arenaExchange()
486 int spins = (NCPU > 1) ? SPINS : 1; in slotExchange() local
489 if (spins > 0) { in slotExchange()
493 else if (h < 0 && (--spins & ((SPINS >>> 1) - 1)) == 0) in slotExchange()
497 spins = SPINS; in slotExchange()
DSynchronousQueue.java438 int spins = shouldSpin(s) in awaitFulfill() local
454 if (spins > 0) in awaitFulfill()
455 spins = shouldSpin(s) ? (spins - 1) : 0; in awaitFulfill()
739 int spins = (head.next == s) in awaitFulfill() local
755 if (spins > 0) in awaitFulfill()
756 --spins; in awaitFulfill()
DPhaser.java1036 int spins = SPINS_PER_ARRIVAL; in internalAwaitAdvance() local
1044 spins += SPINS_PER_ARRIVAL; in internalAwaitAdvance()
1046 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
DLinkedTransferQueue.java696 int spins = -1; // initialized after first item and cancel checks in awaitMatch() local
712 else if (spins < 0) { // establish spins at/near front in awaitMatch()
713 if ((spins = spinsFor(pred, s.isData)) > 0) in awaitMatch()
716 else if (spins > 0) { // spin in awaitMatch()
717 --spins; in awaitMatch()
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DStampedLock.java1035 for (int spins = -1;;) { // spin while enqueuing in acquireWrite()
1041 else if (spins < 0) in acquireWrite()
1042 spins = (m == WBIT && wtail == whead) ? SPINS : 0; in acquireWrite()
1043 else if (spins > 0) { in acquireWrite()
1045 --spins; in acquireWrite()
1063 for (int spins = -1;;) { in acquireWrite()
1066 if (spins < 0) in acquireWrite()
1067 spins = HEAD_SPINS; in acquireWrite()
1068 else if (spins < MAX_HEAD_SPINS) in acquireWrite()
1069 spins <<= 1; in acquireWrite()
[all …]