794                           new ArrayBlockingQueue<Runnable>(10));

   794                           new ArrayBlockingQueue<Runnable>(10));

   795         final CountDownLatch threadsStarted = new CountDownLatch(poolSize);

   795         final CountDownLatch threadsStarted = new CountDownLatch(poolSize);

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

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

   797             threadsStarted.countDown();

   797             threadsStarted.countDown();

   798             try {

   798             try {

   800             } catch (InterruptedException success) {}

   800             } catch (InterruptedException success) {}

   801             ran.getAndIncrement();

   801             ran.getAndIncrement();

   802         }};

   802         }};

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

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

   804             p.execute(waiter);

   804             p.execute(waiter);

  1667         try (PoolCleaner cleaner = cleaner(e)) {

  1667         try (PoolCleaner cleaner = cleaner(e)) {

  1668             List<Callable<String>> l = new ArrayList<>();

  1668             List<Callable<String>> l = new ArrayList<>();

  1669             l.add(latchAwaitingStringTask(latch));

  1669             l.add(latchAwaitingStringTask(latch));

  1670             l.add(null);

  1670             l.add(null);

  1671             try {

  1671             try {

  1673                 shouldThrow();

  1673                 shouldThrow();

  1674             } catch (NullPointerException success) {}

  1674             } catch (NullPointerException success) {}

  1675             latch.countDown();

  1675             latch.countDown();

  1676         }

  1676         }

  1677     }

  1677     }