Searched refs:phaser (Results 1 - 7 of 7) sorted by relevance
/openjdk7/jdk/test/java/util/concurrent/Phaser/ |
H A D | Basic.java | 51 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 D | PhaseOverflow.java | 46 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 D | FickleRegister.java | 60 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 D | Arrive.java | 54 final Phaser phaser = new Phaser(n); 62 int phase = phaser.arrive(); 78 equal(phaser.getPhase(), 1);
|
/openjdk7/jdk/test/java/lang/Thread/ |
H A D | ThreadStateTest.java | 146 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 D | AutoShutdown.java | 54 final Phaser phaser = new Phaser(3); 57 phaser.arriveAndAwaitAdvance(); 65 phaser.arriveAndAwaitAdvance();
|
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | Phaser.java | 50 * 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