Lines Matching refs:Awaiter
134 private static abstract class Awaiter extends Arriver {
135 Awaiter() { super("Awaiter"); }
136 Awaiter(String name) { super(name); }
149 private static Awaiter awaiter(final Phaser phaser) {
150 return new Awaiter() { public void run() {
161 private static Awaiter awaiter(final Phaser phaser,
164 return new Awaiter("InterruptibleWaiter") { public void run() {
196 private static Iterator<Awaiter> awaiterIterator(final Phaser phaser) {
197 return new Iterator<Awaiter>() {
200 public Awaiter next() {
254 Awaiter a1 = awaiter(phaser, 30, SECONDS); a1.start();
278 Iterator<Awaiter> awaiters = awaiterIterator(phaser);
337 Awaiter a1 = awaiter(phaser, timeout, SECONDS); a1.start();
371 Iterator<Awaiter> awaiters = awaiterIterator(phaser);
373 Awaiter a1 = awaiters.next(); a1.start();
374 Awaiter a2 = awaiters.next(); a2.start();