concurrent/Phaser/Basic.java

58     private static void checkTerminated(final Phaser phaser) {
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.register());
70             equal(phase, phaser.awaitAdvanceInterruptibly(0));
71             equal(phase, phaser.awaitAdvanceInterruptibly(0, 10, SECONDS));
75         equal(phaser.getUnarrivedParties(), unarriverParties);
76         equal(phaser.getRegisteredParties(), registeredParties);
152     private static Arriver arriver(final Phaser phaser) {
156             try { phase(phaser.arrive()); }
162     private static Awaiter awaiter(final Phaser phaser) {
168                     phase(phaser.awaitAdvance(phaser.arrive()));
170                     phase(phaser.arriveAndAwaitAdvance());
174     private static Awaiter awaiter(final Phaser phaser,
182                     phase(phaser.awaitAdvanceInterruptibly(phaser.arrive()));
184                     phase(phaser.awaitAdvanceInterruptibly(phaser.arrive(),
191     private static Iterator<Arriver> arriverIterator(final Phaser phaser) {
198                         return arriver(phaser);
200                         return awaiter(phaser);
202                         return awaiter(phaser, -1, SECONDS);
204                         return awaiter(phaser, 30, SECONDS); }}
209     private static Iterator<Awaiter> awaiterIterator(final Phaser phaser) {
216                         return awaiter(phaser);
218                         return awaiter(phaser, -1, SECONDS);
220                         return awaiter(phaser, 30, SECONDS); }}
243             Phaser phaser = new Phaser(3);
244             equal(phaser.getRegisteredParties(), 3);
245             equal(phaser.getArrivedParties(), 0);
246             equal(phaser.getPhase(), 0);
247             check(phaser.getRoot().equals(phaser));
248             equal(phaser.getParent(), null);
249             check(!phaser.isTerminated());
251             Iterator<Arriver> arrivers = arriverIterator(phaser);
254                 equal(phaser.getPhase(), phase++);
258                 phaser.arriveAndAwaitAdvance();
263                 check(!phaser.isTerminated());
264                 equal(phaser.getRegisteredParties(), 3);
265                 equal(phaser.getArrivedParties(), 0);
274             Phaser phaser = new Phaser(3);
275             Iterator<Arriver> arrivers = arriverIterator(phaser);
276             int phase = phaser.getPhase();
278                 check(phaser.getPhase() == phase);
279                 Awaiter a1 = awaiter(phaser, 30, SECONDS); a1.start();
284                 phaser.arriveAndAwaitAdvance();
288                 check(!phaser.isTerminated());
289                 equal(phaser.getRegisteredParties(), 3);
290                 equal(phaser.getArrivedParties(), 0);
301                 Phaser phaser = new Phaser(3);
302                 Iterator<Awaiter> awaiters = awaiterIterator(phaser);
306                 while (phaser.getArrivedParties() < 2) Thread.yield();
307                 equal(0, phaser.getPhase());
308                 phaser.forceTermination();
313                 int arrivedParties = phaser.getArrivedParties();
314                 checkTerminated(phaser);
315                 equal(phaser.getArrivedParties(), arrivedParties);
321         System.out.print("Adds new unarrived parties to this phaser: ");
324             Phaser phaser = new Phaser(1);
325             Iterator<Arriver> arrivers = arriverIterator(phaser);
327             int phase = phaser.getPhase();
330                 check(phaser.getPhase() == phase);
332                 phaser.register(); phaser.register(); phaser.register();
340                 phaser.arriveAndAwaitAdvance();
346                 equal(phaser.getRegisteredParties(), 1 + (3*i));
347                 equal(phaser.getArrivedParties(), 0);
359             Phaser phaser = new Phaser(3);
360             Iterator<Arriver> arrivers = arriverIterator(phaser);
362                 Awaiter a1 = awaiter(phaser, timeout, MILLISECONDS);
369                 phaser.arrive();
372                 check(!phaser.isTerminated());
383             Phaser phaser = new Phaser(3) {
396             kludge[0] = phaser;
397             equal(phaser.getRegisteredParties(), 3);
398             Iterator<Awaiter> awaiters = awaiterIterator(phaser);
403                 while (phaser.getArrivedParties() < 2) Thread.yield();
404                 phaser.arrive();
411                     check(!phaser.isTerminated());
412                     equal(phaser.getRegisteredParties(), 3);
413                     equal(phaser.getArrivedParties(), 0);
414                     equal(phaser.getUnarrivedParties(), 3);
415                     equal(phaser.getPhase(), count.get());
417                     checkTerminated(phaser);