647 |
|
for (int i = 0; i < count; i++) |
648 |
|
p.execute(waiter); |
649 |
|
assertTrue(threadsStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
650 |
+ |
assertEquals(poolSize, p.getActiveCount()); |
651 |
+ |
assertEquals(0, p.getCompletedTaskCount()); |
652 |
|
final List<Runnable> queuedTasks; |
653 |
|
try { |
654 |
|
queuedTasks = p.shutdownNow(); |
661 |
|
assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); |
662 |
|
assertTrue(p.isTerminated()); |
663 |
|
assertEquals(poolSize, ran.get()); |
664 |
+ |
assertEquals(poolSize, p.getCompletedTaskCount()); |
665 |
|
} |
666 |
|
|
667 |
|
// Exception Tests |