Home
last modified time | relevance | path

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

/libcore/luni/src/main/java/java/util/concurrent/
DExchanger.java353 for (int h = p.hash, spins = SPINS;;) { in arenaExchange()
361 else if (spins > 0) { in arenaExchange()
366 (--spins & ((SPINS >>> 1) - 1)) == 0) in arenaExchange()
370 spins = SPINS; // releaser hasn't set match yet in arenaExchange()
461 int spins = (NCPU > 1) ? SPINS : 1; in slotExchange() local
464 if (spins > 0) { in slotExchange()
468 else if (h < 0 && (--spins & ((SPINS >>> 1) - 1)) == 0) in slotExchange()
472 spins = SPINS; in slotExchange()
DSynchronousQueue.java407 int spins = (shouldSpin(s) ? in awaitFulfill() local
422 if (spins > 0) in awaitFulfill()
423 spins = shouldSpin(s) ? (spins-1) : 0; in awaitFulfill()
711 int spins = ((head.next == s) ? in awaitFulfill() local
726 if (spins > 0) in awaitFulfill()
727 --spins; in awaitFulfill()
DLinkedTransferQueue.java671 int spins = -1; // initialized after first item and cancel checks in awaitMatch() local
687 if (spins < 0) { // establish spins at/near front in awaitMatch()
688 if ((spins = spinsFor(pred, s.isData)) > 0) in awaitMatch()
691 else if (spins > 0) { // spin in awaitMatch()
692 --spins; in awaitMatch()
DPhaser.java1012 int spins = SPINS_PER_ARRIVAL; in internalAwaitAdvance() local
1020 spins += SPINS_PER_ARRIVAL; in internalAwaitAdvance()
1022 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
DForkJoinPool.java1250 int spins = PL_SPINS, ps, nps; in acquirePlock() local
1255 else if (spins >= 0) { in acquirePlock()
1257 --spins; in acquirePlock()