Searched refs:spins (Results 1 – 5 of 5) sorted by relevance
377 for (int h = p.hash, spins = SPINS;;) { in arenaExchange()385 else if (spins > 0) { in arenaExchange()390 (--spins & ((SPINS >>> 1) - 1)) == 0) in arenaExchange()394 spins = SPINS; // releaser hasn't set match yet in arenaExchange()487 int spins = (NCPU > 1) ? SPINS : 1; in slotExchange() local490 if (spins > 0) { in slotExchange()494 else if (h < 0 && (--spins & ((SPINS >>> 1) - 1)) == 0) in slotExchange()498 spins = SPINS; in slotExchange()
1035 int spins = SPINS_PER_ARRIVAL; in internalAwaitAdvance() local1043 spins += SPINS_PER_ARRIVAL; in internalAwaitAdvance()1045 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
1202 byte spins = 0, postSpins = 0; // retries upon unpark of first thread in acquireWrite()1240 } else if (first && spins != 0) { // reduce unfairness in acquireWrite()1241 --spins; in acquireWrite()1249 spins = postSpins = (byte)((postSpins << 1) | 1); in acquireWrite()1341 byte spins = 0, postSpins = 0; // retries upon unpark of first thread in acquireRead()1367 } else if (first && spins != 0) { in acquireRead()1368 --spins; in acquireRead()1376 spins = postSpins = (byte)((postSpins << 1) | 1); in acquireRead()
274 byte spins = 0, postSpins = 0; // retries upon unpark of first thread in acquire()341 } else if (first && spins != 0) { in acquire()342 --spins; // reduce unfairness on rewaits in acquire()348 spins = postSpins = (byte)((postSpins << 1) | 1); in acquire()
639 byte spins = 0, postSpins = 0; // retries upon unpark of first thread in acquire()706 } else if (first && spins != 0) { in acquire()707 --spins; // reduce unfairness on rewaits in acquire()713 spins = postSpins = (byte)((postSpins << 1) | 1); in acquire()