344 |
|
await(done); |
345 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
346 |
|
}}); |
347 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
347 |
> |
await(threadsStarted); |
348 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
349 |
|
} |
350 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
662 |
|
}}; |
663 |
|
for (int i = 0; i < count; i++) |
664 |
|
p.execute(waiter); |
665 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
665 |
> |
await(threadsStarted); |
666 |
|
assertEquals(poolSize, p.getActiveCount()); |
667 |
|
assertEquals(0, p.getCompletedTaskCount()); |
668 |
|
final List<Runnable> queuedTasks; |