697                                    new ArrayBlockingQueue<Runnable>(10));

   697                                    new ArrayBlockingQueue<Runnable>(10));

   698         final CountDownLatch threadsStarted = new CountDownLatch(poolSize);

   698         final CountDownLatch threadsStarted = new CountDownLatch(poolSize);

   699         Runnable waiter = new CheckedRunnable() { public void realRun() {

   699         Runnable waiter = new CheckedRunnable() { public void realRun() {

   700             threadsStarted.countDown();

   700             threadsStarted.countDown();

   701             try {

   701             try {

   703             } catch (InterruptedException success) {}

   703             } catch (InterruptedException success) {}

   704             ran.getAndIncrement();

   704             ran.getAndIncrement();

   705         }};

   705         }};

   706         for (int i = 0; i < count; i++)

   706         for (int i = 0; i < count; i++)

   707             p.execute(waiter);

   707             p.execute(waiter);