Searched defs:phase (Results 1 – 2 of 2) sorted by relevance
322 private AtomicReference<QNode> queueFor(int phase) { in queueFor()355 int phase = (int)(s >>> PHASE_SHIFT); in doArrive() local400 int phase; in doRegister() local461 int phase, p; in reconcileState() local522 int phase = 0; in Phaser() local648 int phase = (int)(s >>> PHASE_SHIFT); in arriveAndAwaitAdvance() local690 public int awaitAdvance(int phase) { in awaitAdvance()716 public int awaitAdvanceInterruptibly(int phase) in awaitAdvanceInterruptibly()752 public int awaitAdvanceInterruptibly(int phase, in awaitAdvanceInterruptibly()907 protected boolean onAdvance(int phase, int registeredParties) { in onAdvance()[all …]
38 int phase, int parties, int unarrived) { in assertState()271 int phase = phaser.arrive(); in testPhaseIncrement1() local