concurrent/Phaser/Basic.java

147     private abstract static class Awaiter extends Arriver {
148         Awaiter() { super("Awaiter"); }
149         Awaiter(String name) { super(name); }
162     private static Awaiter awaiter(final Phaser phaser) {
163         return new Awaiter() { public void run() {
174     private static Awaiter awaiter(final Phaser phaser,
177         return new Awaiter("InterruptibleWaiter") { public void run() {
209     private static Iterator<Awaiter> awaiterIterator(final Phaser phaser) {
210         return new Iterator<Awaiter>() {
213             public Awaiter next() {
279                 Awaiter a1 = awaiter(phaser, 30, SECONDS); a1.start();
302                 Iterator<Awaiter> awaiters = awaiterIterator(phaser);
362                 Awaiter a1 = awaiter(phaser, timeout, MILLISECONDS);
398             Iterator<Awaiter> awaiters = awaiterIterator(phaser);
400                 Awaiter a1 = awaiters.next(); a1.start();
401                 Awaiter a2 = awaiters.next(); a2.start();