concurrent/CyclicBarrier/Basic.java

62     private static void checkResult(Awaiter a, Class<? extends Throwable> c) {
93     private abstract static class Awaiter extends Thread {
97             this.setName("Awaiter:"+count.getAndIncrement());
106     private static Awaiter awaiter(final CyclicBarrier barrier) {
107         return new Awaiter() { public void run() {
114     private static Awaiter awaiter(final CyclicBarrier barrier,
116         return new Awaiter() { public void run() {
124     private static Iterator<Awaiter> awaiterIterator(final CyclicBarrier barrier) {
125         return new Iterator<Awaiter>() {
128             public Awaiter next() {
147             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
150                     Awaiter a1 = awaiters.next(); a1.start();
151                     Awaiter a2 = awaiters.next(); a2.start();
170             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
172                 Awaiter a1 = awaiters.next(); a1.start();
173                 Awaiter a2 = awaiters.next(); a2.start();
190             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
192                 Awaiter a1 = awaiters.next(); a1.start();
193                 Awaiter a2 = awaiters.next(); a2.start();
212             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
215                     Awaiter a1 = awaiter(barrier, timeout); a1.start();
216                     Awaiter a2 = awaiters.next();           a2.start();
243             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
245                 Awaiter a1 = awaiters.next(); a1.start();
246                 Awaiter a2 = awaiters.next(); a2.start();
269             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
271                 Awaiter a1 = awaiters.next(); a1.start();
272                 Awaiter a2 = awaiters.next(); a2.start();
300          * A version of Awaiter that also records interrupted state.