Searched refs:phaser (Results 1 - 7 of 7) sorted by relevance

/openjdk7/jdk/test/java/util/concurrent/Phaser/
H A DBasic.java51 private static void checkTerminated(final Phaser phaser) { argument
52 check(phaser.isTerminated());
53 int unarriverParties = phaser.getUnarrivedParties();
54 int registeredParties = phaser.getRegisteredParties();
55 int phase = phaser.getPhase();
57 equal(phase, phaser.arrive());
58 equal(phase, phaser.arriveAndDeregister());
59 equal(phase, phaser.arriveAndAwaitAdvance());
60 equal(phase, phaser.bulkRegister(10));
61 equal(phase, phaser
139 arriver(final Phaser phaser) argument
149 awaiter(final Phaser phaser) argument
161 awaiter(final Phaser phaser, final long timeout, final TimeUnit unit) argument
178 arriverIterator(final Phaser phaser) argument
196 awaiterIterator(final Phaser phaser) argument
[all...]
H A DPhaseOverflow.java46 void checkState(Phaser phaser, argument
48 equal(phase, phaser.getPhase());
49 equal(parties, phaser.getRegisteredParties());
50 equal(unarrived, phaser.getUnarrivedParties());
61 Phaser phaser = new Phaser();
63 stateField.setLong(phaser, ((Integer.MAX_VALUE - 1L) << 32) | 1L);
64 checkState(phaser, Integer.MAX_VALUE - 1, 0, 0);
65 phaser.register();
66 checkState(phaser, Integer.MAX_VALUE - 1, 1, 1);
67 phaser
[all...]
H A DFickleRegister.java60 Runner(Phaser phaser) { p = phaser; } argument
118 for (Phaser phaser : phasers) {
119 check(phaser.getPhase() > 0);
120 equal(0, phaser.getRegisteredParties());
121 equal(0, phaser.getUnarrivedParties());
122 equal(parent.getPhase(), phaser.getPhase());
H A DArrive.java54 final Phaser phaser = new Phaser(n);
62 int phase = phaser.arrive();
78 equal(phaser.getPhase(), 1);
/openjdk7/jdk/test/java/lang/Thread/
H A DThreadStateTest.java146 private Phaser phaser = new Phaser(2); field in class:ThreadStateTest.MyThread
166 phaser.arriveAndAwaitAdvance();
181 phaser.arrive();
192 phaser.arrive();
205 phaser.arrive();
217 phaser.arrive();
226 phaser.arrive();
237 phaser.arrive();
249 phaser.arrive();
260 phaser
[all...]
/openjdk7/jdk/test/java/util/concurrent/Executors/
H A DAutoShutdown.java54 final Phaser phaser = new Phaser(3);
57 phaser.arriveAndAwaitAdvance();
65 phaser.arriveAndAwaitAdvance();
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DPhaser.java50 * number of parties <em>registered</em> to synchronize on a phaser
66 * generation of a phaser has an associated phase number. The phase
68 * phaser, wrapping around to zero after reaching {@code
70 * control of actions upon arrival at a phaser and upon awaiting
79 * number</em>; that is, the phase number of the phaser to which
91 * the phaser advances to (or is already at) a different phase.
97 * state of the phaser. If necessary, you can perform any
106 * <p> <b>Termination.</b> A phaser may enter a <em>termination</em>
131 * Whenever the number of registered parties of a child phaser becomes
134 * child phaser i
1079 final Phaser phaser; field in class:Phaser.QNode
1089 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
[all...]

Completed in 44 milliseconds