Searched defs:phaser (Results 1 - 4 of 4) sorted by relevance
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | DoubleAccumulatorTest.java | 129 Phaser phaser = new Phaser(nthreads + 1); 131 pool.execute(new AccTask(a, phaser, incs)); 132 phaser.arriveAndAwaitAdvance(); 133 phaser.arriveAndAwaitAdvance(); 142 final Phaser phaser; field in class:DoubleAccumulatorTest.AccTask 145 AccTask(DoubleAccumulator acc, Phaser phaser, int incs) { argument 147 this.phaser = phaser; 152 phaser.arriveAndAwaitAdvance(); 157 phaser [all...] |
H A D | LongAccumulatorTest.java | 129 Phaser phaser = new Phaser(nthreads + 1); 131 pool.execute(new AccTask(a, phaser, incs)); 132 phaser.arriveAndAwaitAdvance(); 133 phaser.arriveAndAwaitAdvance(); 142 final Phaser phaser; field in class:LongAccumulatorTest.AccTask 145 AccTask(LongAccumulator acc, Phaser phaser, int incs) { argument 147 this.phaser = phaser; 152 phaser.arriveAndAwaitAdvance(); 157 phaser [all...] |
H A D | PhaserTest.java | 36 /** Checks state of unterminated phaser. */ 37 protected void assertState(Phaser phaser, argument 39 assertEquals(phase, phaser.getPhase()); 40 assertEquals(parties, phaser.getRegisteredParties()); 41 assertEquals(unarrived, phaser.getUnarrivedParties()); 42 assertEquals(parties - unarrived, phaser.getArrivedParties()); 43 assertFalse(phaser.isTerminated()); 46 /** Checks state of terminated phaser. */ 47 protected void assertTerminated(Phaser phaser, int maxPhase, int parties) { argument 48 assertTrue(phaser 57 assertTerminated(Phaser phaser, int maxPhase) argument [all...] |
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | Phaser.java | 19 * number of parties <em>registered</em> to synchronize on a phaser 35 * generation of a phaser has an associated phase number. The phase 37 * phaser, wrapping around to zero after reaching {@code 39 * control of actions upon arrival at a phaser and upon awaiting 48 * number</em>; that is, the phase number of the phaser to which 60 * the phaser advances to (or is already at) a different phase. 66 * state of the phaser. If necessary, you can perform any 76 * <p><b>Termination.</b> A phaser may enter a <em>termination</em> 101 * Whenever the number of registered parties of a child phaser becomes 104 * child phaser i 1056 final Phaser phaser; field in class:Phaser.QNode 1066 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument [all...] |
Completed in 30 milliseconds