Searched defs:phaser (Results 1 - 4 of 4) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
H A DDoubleAccumulatorTest.java129 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 DLongAccumulatorTest.java129 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 DPhaserTest.java36 /** 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 DPhaser.java19 * 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