equal
deleted
inserted
replaced
705 final CustomExecutor p = new CustomExecutor(poolSize); |
705 final CustomExecutor p = new CustomExecutor(poolSize); |
706 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); |
706 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); |
707 Runnable waiter = new CheckedRunnable() { public void realRun() { |
707 Runnable waiter = new CheckedRunnable() { public void realRun() { |
708 threadsStarted.countDown(); |
708 threadsStarted.countDown(); |
709 try { |
709 try { |
710 MILLISECONDS.sleep(2 * LONG_DELAY_MS); |
710 MILLISECONDS.sleep(LONGER_DELAY_MS); |
711 } catch (InterruptedException success) {} |
711 } catch (InterruptedException success) {} |
712 ran.getAndIncrement(); |
712 ran.getAndIncrement(); |
713 }}; |
713 }}; |
714 for (int i = 0; i < count; i++) |
714 for (int i = 0; i < count; i++) |
715 p.execute(waiter); |
715 p.execute(waiter); |