115 |
|
assertEquals(1, p.getActiveCount()); |
116 |
|
await(done); |
117 |
|
}}); |
118 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
118 |
> |
await(threadStarted); |
119 |
|
assertEquals(1, p.getActiveCount()); |
120 |
|
done.countDown(); |
121 |
|
} |
387 |
|
assertEquals(1, p.getPoolSize()); |
388 |
|
await(done); |
389 |
|
}}); |
390 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
390 |
> |
await(threadStarted); |
391 |
|
assertEquals(1, p.getPoolSize()); |
392 |
|
} |
393 |
|
} |
411 |
|
threadStarted.countDown(); |
412 |
|
await(done); |
413 |
|
}}); |
414 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
414 |
> |
await(threadStarted); |
415 |
|
assertEquals(1, p.getTaskCount()); |
416 |
|
assertEquals(0, p.getCompletedTaskCount()); |
417 |
|
for (int i = 0; i < TASKS; i++) { |
495 |
|
threadStarted.countDown(); |
496 |
|
await(done); |
497 |
|
}}); |
498 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
498 |
> |
await(threadStarted); |
499 |
|
assertFalse(p.isTerminating()); |
500 |
|
done.countDown(); |
501 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
523 |
|
threadStarted.countDown(); |
524 |
|
await(done); |
525 |
|
}}); |
526 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
526 |
> |
await(threadStarted); |
527 |
|
assertFalse(p.isTerminating()); |
528 |
|
done.countDown(); |
529 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
557 |
|
tasks[i] = new FutureTask(task); |
558 |
|
p.execute(tasks[i]); |
559 |
|
} |
560 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
560 |
> |
await(threadStarted); |
561 |
|
assertSame(q, p.getQueue()); |
562 |
|
assertFalse(q.contains(tasks[0])); |
563 |
|
assertTrue(q.contains(tasks[tasks.length - 1])); |
587 |
|
}}; |
588 |
|
p.execute(tasks[i]); |
589 |
|
} |
590 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
590 |
> |
await(threadStarted); |
591 |
|
assertFalse(p.remove(tasks[0])); |
592 |
|
assertTrue(q.contains(tasks[4])); |
593 |
|
assertTrue(q.contains(tasks[3])); |
624 |
|
tasks[i] = new FutureTask(task); |
625 |
|
p.execute(tasks[i]); |
626 |
|
} |
627 |
< |
assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
627 |
> |
await(threadStarted); |
628 |
|
assertEquals(tasks.length, p.getTaskCount()); |
629 |
|
assertEquals(tasks.length - 1, q.size()); |
630 |
|
assertEquals(1L, p.getActiveCount()); |
2044 |
|
}}; |
2045 |
|
futures.add(e.submit(r)); |
2046 |
|
} |
2047 |
< |
assertTrue(blockerStarted.await(LONG_DELAY_MS, MILLISECONDS)); |
2047 |
> |
await(blockerStarted); |
2048 |
|
for (Future<?> future : futures) future.cancel(false); |
2049 |
|
for (Future<?> future : futures) { |
2050 |
|
try { |