Cross Reference: /openjdk7/jdk/test/java/util/concurrent/CyclicBarrier/Basic.java

Lines Matching refs:Awaiter
55     private static void checkResult(Awaiter a, Class<? extends Throwable> c) {
86     private abstract static class Awaiter extends Thread {
90             this.setName("Awaiter:"+count.getAndIncrement());
99     private static Awaiter awaiter(final CyclicBarrier barrier) {
100         return new Awaiter() { public void run() {
107     private static Awaiter awaiter(final CyclicBarrier barrier,
109         return new Awaiter() { public void run() {
117     private static Iterator<Awaiter> awaiterIterator(final CyclicBarrier barrier) {
118         return new Iterator<Awaiter>() {
121             public Awaiter next() {
140             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
143                     Awaiter a1 = awaiters.next(); a1.start();
144                     Awaiter a2 = awaiters.next(); a2.start();
163             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
165                 Awaiter a1 = awaiters.next(); a1.start();
166                 Awaiter a2 = awaiters.next(); a2.start();
183             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
185                 Awaiter a1 = awaiters.next(); a1.start();
186                 Awaiter a2 = awaiters.next(); a2.start();
205             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
208                     Awaiter a1 = awaiter(barrier, timeout); a1.start();
209                     Awaiter a2 = awaiters.next();           a2.start();
236             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
238                 Awaiter a1 = awaiters.next(); a1.start();
239                 Awaiter a2 = awaiters.next(); a2.start();
262             Iterator<Awaiter> awaiters = awaiterIterator(barrier);
264                 Awaiter a1 = awaiters.next(); a1.start();
265                 Awaiter a2 = awaiters.next(); a2.start();
293          * A version of Awaiter that also records interrupted state.