/openjdk9/jdk/test/java/util/concurrent/tck/ |
H A D | PhaserTest.java | 59 /** Checks state of unterminated phaser. */ 60 protected void assertState(Phaser phaser, argument 62 assertEquals(phase, phaser.getPhase()); 63 assertEquals(parties, phaser.getRegisteredParties()); 64 assertEquals(unarrived, phaser.getUnarrivedParties()); 65 assertEquals(parties - unarrived, phaser.getArrivedParties()); 66 assertFalse(phaser.isTerminated()); 69 /** Checks state of terminated phaser. */ 70 protected void assertTerminated(Phaser phaser, int maxPhase, int parties) { argument 71 assertTrue(phaser 80 assertTerminated(Phaser phaser, int maxPhase) argument [all...] |
H A D | DoubleAccumulatorTest.java | 151 Phaser phaser = new Phaser(nthreads + 1); 153 pool.execute(new AccTask(a, phaser, incs)); 154 phaser.arriveAndAwaitAdvance(); 155 phaser.arriveAndAwaitAdvance(); 164 final Phaser phaser; field in class:DoubleAccumulatorTest.AccTask 167 AccTask(DoubleAccumulator acc, Phaser phaser, int incs) { argument 169 this.phaser = phaser; 174 phaser.arriveAndAwaitAdvance(); 179 phaser [all...] |
H A D | LongAccumulatorTest.java | 151 Phaser phaser = new Phaser(nthreads + 1); 153 pool.execute(new AccTask(a, phaser, incs)); 154 phaser.arriveAndAwaitAdvance(); 155 phaser.arriveAndAwaitAdvance(); 164 final Phaser phaser; field in class:LongAccumulatorTest.AccTask 167 AccTask(LongAccumulator acc, Phaser phaser, int incs) { argument 169 this.phaser = phaser; 174 phaser.arriveAndAwaitAdvance(); 179 phaser [all...] |
/openjdk9/jdk/test/java/util/concurrent/Phaser/ |
H A D | Basic.java | 58 private static void checkTerminated(final Phaser phaser) { argument 59 check(phaser.isTerminated()); 60 int unarriverParties = phaser.getUnarrivedParties(); 61 int registeredParties = phaser.getRegisteredParties(); 62 int phase = phaser.getPhase(); 64 equal(phase, phaser.arrive()); 65 equal(phase, phaser.arriveAndDeregister()); 66 equal(phase, phaser.arriveAndAwaitAdvance()); 67 equal(phase, phaser.bulkRegister(10)); 68 equal(phase, phaser 152 arriver(final Phaser phaser) argument 162 awaiter(final Phaser phaser) argument 174 awaiter(final Phaser phaser, final long timeout, final TimeUnit unit) argument 191 arriverIterator(final Phaser phaser) argument 209 awaiterIterator(final Phaser phaser) argument [all...] |
H A D | PhaseOverflow.java | 47 void checkState(Phaser phaser, argument 49 equal(phase, phaser.getPhase()); 50 equal(parties, phaser.getRegisteredParties()); 51 equal(unarrived, phaser.getUnarrivedParties()); 62 Phaser phaser = new Phaser(); 64 stateField.setLong(phaser, ((Integer.MAX_VALUE - 1L) << 32) | 1L); 65 checkState(phaser, Integer.MAX_VALUE - 1, 0, 0); 66 phaser.register(); 67 checkState(phaser, Integer.MAX_VALUE - 1, 1, 1); 68 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);
|
/openjdk9/jdk/test/java/util/concurrent/atomic/ |
H A D | DoubleAdderDemo.java | 86 Phaser phaser = new Phaser(nthreads + 1); 89 pool.execute(new SyncTask(a, phaser, incs)); 90 report(nthreads, incs, timeTasks(phaser), a.sum()); 95 Phaser phaser = new Phaser(nthreads + 1); 98 pool.execute(new AdderTask(a, phaser, incs)); 99 report(nthreads, incs, timeTasks(phaser), a.sum()); 112 static long timeTasks(Phaser phaser) { argument 113 phaser.arriveAndAwaitAdvance(); 115 phaser.arriveAndAwaitAdvance(); 116 phaser 122 final Phaser phaser; field in class:DoubleAdderDemo.AdderTask 125 AdderTask(DoubleAdder adder, Phaser phaser, int incs) argument 144 final Phaser phaser; field in class:DoubleAdderDemo.SyncTask 147 SyncTask(SynchronizedDoubleAdder adder, Phaser phaser, int incs) argument [all...] |
H A D | LongAdderDemo.java | 80 Phaser phaser = new Phaser(nthreads + 1); 83 pool.execute(new CasTask(a, phaser, incs)); 84 report(nthreads, incs, timeTasks(phaser), a.get()); 89 Phaser phaser = new Phaser(nthreads + 1); 92 pool.execute(new AdderTask(a, phaser, incs)); 93 report(nthreads, incs, timeTasks(phaser), a.sum()); 106 static long timeTasks(Phaser phaser) { argument 107 phaser.arriveAndAwaitAdvance(); 109 phaser.arriveAndAwaitAdvance(); 110 phaser 116 final Phaser phaser; field in class:LongAdderDemo.AdderTask 119 AdderTask(LongAdder adder, Phaser phaser, int incs) argument 138 final Phaser phaser; field in class:LongAdderDemo.CasTask 141 CasTask(AtomicLong adder, Phaser phaser, int incs) argument [all...] |
/openjdk9/hotspot/test/compiler/whitebox/ |
H A D | DeoptimizeFramesTest.java | 57 private final Phaser phaser; field in class:DeoptimizeFramesTest 59 private DeoptimizeFramesTest(boolean makeNotEntrant, Phaser phaser) { argument 60 super(new TestCaseImpl(phaser)); 64 this.phaser = phaser; 88 phaser.register(); 92 int p = phaser.arriveAndAwaitAdvance(); 95 phaser.awaitAdvance(phaser.arriveAndDeregister()); 128 private final Phaser phaser; field in class:DeoptimizeFramesTest.TestCaseImpl 130 TestCaseImpl(Phaser phaser) argument [all...] |
/openjdk9/jdk/test/java/util/concurrent/forkjoin/ |
H A D | ThrowingRunnable.java | 51 static final Phaser phaser = new Phaser(2); field in class:ThrowingRunnable 56 phaser.awaitAdvanceInterruptibly(phaser.arrive(), 10, TimeUnit.SECONDS); 68 phaser.arrive();
|
/openjdk9/jdk/test/java/lang/management/ThreadMXBean/ |
H A D | ThreadStackTrace.java | 151 private final Phaser phaser; field in class:ThreadStackTrace.BlockedThread 153 BlockedThread(String name, Phaser phaser) { argument 155 this.phaser = phaser; 168 phaser.arriveAndAwaitAdvance(); 177 phaser.arriveAndAwaitAdvance(); 184 phaser.arriveAndAwaitAdvance(); 205 private final Phaser phaser; field in class:ThreadStackTrace.Examiner 207 Examiner(String name, Phaser phaser) { argument 209 this.phaser [all...] |
/openjdk9/jdk/test/java/net/Socket/asyncClose/ |
H A D | Race.java | 44 final Phaser phaser = new Phaser(THREADS + 1); 56 phaser.arriveAndAwaitAdvance(); 69 phaser.arriveAndAwaitAdvance();
|
/openjdk9/jdk/test/sun/net/www/http/KeepAliveStream/ |
H A D | InfiniteLoop.java | 54 final Phaser phaser = new Phaser(2); 61 phaser.arriveAndAwaitAdvance(); 67 phaser.arriveAndAwaitAdvance();
|
/openjdk9/jdk/test/java/lang/Thread/ |
H A D | ThreadStateController.java | 85 private final Phaser phaser = new Phaser(2); field in class:ThreadStateController 229 phaser.arrive(); 231 getId(), toStateName(nextState), phaserToString(phaser)); 282 id, toStateName(s), phaserToString(phaser)); 284 int phase = phaser.arrive(); 286 id, toStateName(s), phaserToString(phaser)); 290 // or unpark. Hence await for the phaser to advance with timeout 311 phaser.awaitAdvanceInterruptibly(phase, 100, TimeUnit.MILLISECONDS); 313 id, toStateName(s), phaserToString(phaser)); 317 log("%d: Timeout: %s%n", id, phaser); [all...] |
/openjdk9/jdk/test/java/lang/management/MemoryMXBean/ |
H A D | LowMemoryTest.java | 54 private static final Phaser phaser = new Phaser(2); field in class:LowMemoryTest 286 phaser.arriveAndAwaitAdvance(); 293 phaser.arriveAndAwaitAdvance(); 350 phaser.arriveAndAwaitAdvance(); 352 " phase " + phaser.getPhase()); 355 phaser.arriveAndAwaitAdvance(); 357 " phase " + phaser.getPhase()); 392 phaser.arriveAndAwaitAdvance(); 394 " phase " + phaser.getPhase()); 401 phaser [all...] |
/openjdk9/jdk/test/java/util/logging/LogManager/ |
H A D | TestLoggerNames.java | 97 static volatile Phaser phaser = new Phaser(2); field in class:TestLoggerNames 164 phaser.arriveAndAwaitAdvance(); 172 // phaser. 173 phaser.arrive(); 216 // phaser first. We don't really care if the logger is actually 224 // to the phaser yet... 238 phaser.arriveAndAwaitAdvance(); 254 phaser.arriveAndDeregister();
|
/openjdk9/jdk/src/java.base/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 107 * <p><b>Termination.</b> A phaser may enter a <em>termination</em> 132 * Whenever the number of registered parties of a child phaser becomes 135 * child phaser i 1081 final Phaser phaser; field in class:Phaser.QNode 1091 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument [all...] |
/openjdk9/jdk/test/java/util/concurrent/CompletableFuture/ |
H A D | Basic.java | 172 final Phaser phaser = new Phaser(1); 173 final int phase = phaser.getPhase(); 175 cf = supplyAsync(() -> { phaser.awaitAdvance(phase); return 1; }); 177 phaser.arrive(); 180 cf = supplyAsync(() -> { phaser.awaitAdvance(phase+1); return 1; }); 182 phaser.arrive(); 185 cf = supplyAsync(() -> { phaser.awaitAdvance(phase+2); return 1; }); 187 phaser.arrive(); 190 cf = supplyAsync(() -> { phaser.awaitAdvance(phase+3); return 1; }); 192 phaser [all...] |