Searched refs:phase (Results 1 – 3 of 3) sorted by relevance
351 private AtomicReference<QNode> queueFor(int phase) { in queueFor() argument352 return ((phase & 1) == 0) ? evenQ : oddQ; in queueFor()384 int phase = (int)(s >>> PHASE_SHIFT); in doArrive() local385 if (phase < 0) in doArrive()386 return phase; in doArrive()396 if (onAdvance(phase, nextUnarrived)) in doArrive()402 int nextPhase = (phase + 1) & MAX_PHASE; in doArrive()405 releaseWaiters(phase); in doArrive()408 phase = parent.doArrive(ONE_DEREGISTER); in doArrive()412 phase = parent.doArrive(ONE_ARRIVAL); in doArrive()[all …]
62 int phase, int parties, int unarrived) { in assertState() argument63 assertEquals(phase, phaser.getPhase()); in assertState()295 int phase = phaser.arrive(); in testPhaseIncrement1() local296 … assertTrue(index % size == 0 ? (index / size) == phase : index - (phase * size) > 0); in testPhaseIncrement1()
38 int phase, int parties, int unarrived) { in assertState() argument39 assertEquals(phase, phaser.getPhase()); in assertState()271 int phase = phaser.arrive(); in testPhaseIncrement1() local272 … assertTrue(index % size == 0 ? (index / size) == phase : index - (phase * size) > 0); in testPhaseIncrement1()