# | Line 711 | Line 711 | public class ThreadPoolExecutorSubclassT | |
---|---|---|
711 | new CustomTPE(poolSize, poolSize, LONG_DELAY_MS, MILLISECONDS, | |
712 | new ArrayBlockingQueue<Runnable>(10)); | |
713 | CountDownLatch threadsStarted = new CountDownLatch(poolSize); | |
714 | < | CheckedRunnable waiter = new CheckedRunnable() { public void realRun() { |
714 | > | Runnable waiter = new CheckedRunnable() { public void realRun() { |
715 | threadsStarted.countDown(); | |
716 | try { | |
717 | MILLISECONDS.sleep(2 * LONG_DELAY_MS); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |