491 |
|
await(done); |
492 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
493 |
|
}}); |
494 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
494 |
> |
await(threadsStarted); |
495 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
496 |
|
} |
497 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
777 |
|
}}; |
778 |
|
for (int i = 0; i < count; i++) |
779 |
|
p.execute(waiter); |
780 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
780 |
> |
await(threadsStarted); |
781 |
|
assertEquals(poolSize, p.getActiveCount()); |
782 |
|
assertEquals(0, p.getCompletedTaskCount()); |
783 |
|
final List<Runnable> queuedTasks; |