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

/openjdk10/jdk/test/java/util/concurrent/Phaser/
H A DBasic.java58 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 DPhaseOverflow.java47 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 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);
/openjdk10/jdk/test/java/util/concurrent/tck/
H A DPhaserTest.java59 /** 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 DDoubleAccumulatorTest.java158 final Phaser phaser = new Phaser(nThreads + 1);
162 phaser.arriveAndAwaitAdvance();
167 phaser.arrive();
173 phaser.arriveAndAwaitAdvance();
174 phaser.arriveAndAwaitAdvance();
H A DLongAccumulatorTest.java152 final Phaser phaser = new Phaser(nThreads + 1);
156 phaser.arriveAndAwaitAdvance();
161 phaser.arrive();
167 phaser.arriveAndAwaitAdvance();
168 phaser.arriveAndAwaitAdvance();
/openjdk10/jdk/test/java/util/concurrent/atomic/
H A DDoubleAdderDemo.java86 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 DLongAdderDemo.java80 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...]
/openjdk10/hotspot/test/compiler/whitebox/
H A DDeoptimizeFramesTest.java57 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...]
/openjdk10/jdk/test/java/util/concurrent/forkjoin/
H A DThrowingRunnable.java51 static final Phaser phaser = new Phaser(2); field in class:ThrowingRunnable
56 phaser.awaitAdvanceInterruptibly(phaser.arrive(), 10, TimeUnit.SECONDS);
68 phaser.arrive();
/openjdk10/jdk/test/java/lang/management/ThreadMXBean/
H A DThreadStackTrace.java151 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...]
/openjdk10/jdk/test/java/net/Socket/asyncClose/
H A DRace.java44 final Phaser phaser = new Phaser(THREADS + 1);
56 phaser.arriveAndAwaitAdvance();
69 phaser.arriveAndAwaitAdvance();
/openjdk10/jdk/test/sun/net/www/http/KeepAliveStream/
H A DInfiniteLoop.java54 final Phaser phaser = new Phaser(2);
61 phaser.arriveAndAwaitAdvance();
67 phaser.arriveAndAwaitAdvance();
/openjdk10/jdk/test/java/lang/Thread/
H A DThreadStateController.java85 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...]
/openjdk10/jdk/test/java/lang/management/MemoryMXBean/
H A DLowMemoryTest.java53 private static final Phaser phaser = new Phaser(2); field in class:LowMemoryTest
285 phaser.arriveAndAwaitAdvance();
292 phaser.arriveAndAwaitAdvance();
349 phaser.arriveAndAwaitAdvance();
351 " phase " + phaser.getPhase());
354 phaser.arriveAndAwaitAdvance();
356 " phase " + phaser.getPhase());
391 phaser.arriveAndAwaitAdvance();
393 " phase " + phaser.getPhase());
400 phaser
[all...]
/openjdk10/jdk/test/java/util/logging/LogManager/
H A DTestLoggerNames.java97 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();
/openjdk10/jdk/test/java/net/NetworkInterface/
H A DGetMacAddress.java51 public GetMacAddress(NetworkInterface ni, String name, Phaser phaser) { argument
54 this.startingGate = phaser;
/openjdk10/jdk/src/java.base/share/classes/java/util/concurrent/
H A DPhaser.java49 * number of parties <em>registered</em> to synchronize on a phaser
65 * generation of a phaser has an associated phase number. The phase
67 * phaser, wrapping around to zero after reaching {@code
69 * control of actions upon arrival at a phaser and upon awaiting
78 * number</em>; that is, the phase number of the phaser to which
90 * the phaser advances to (or is already at) a different phase.
96 * 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
1080 final Phaser phaser; field in class:Phaser.QNode
1090 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
[all...]
/openjdk10/jdk/test/java/util/concurrent/CompletableFuture/
H A DBasic.java172 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...]

Completed in 197 milliseconds