437 |
|
await(done); |
438 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
439 |
|
}}); |
440 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
440 |
> |
await(threadsStarted); |
441 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
442 |
|
} |
443 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
702 |
|
}}; |
703 |
|
for (int i = 0; i < count; i++) |
704 |
|
p.execute(waiter); |
705 |
< |
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
705 |
> |
await(threadsStarted); |
706 |
|
assertEquals(poolSize, p.getActiveCount()); |
707 |
|
assertEquals(0, p.getCompletedTaskCount()); |
708 |
|
final List<Runnable> queuedTasks; |