389 |
|
assertEquals(1, p.getActiveCount()); |
390 |
|
done.await(); |
391 |
|
}}); |
392 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
392 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
393 |
|
assertEquals(1, p.getActiveCount()); |
394 |
|
} finally { |
395 |
|
done.countDown(); |
482 |
|
assertEquals(1, p.getPoolSize()); |
483 |
|
done.await(); |
484 |
|
}}); |
485 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
485 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
486 |
|
assertEquals(1, p.getPoolSize()); |
487 |
|
} finally { |
488 |
|
done.countDown(); |
507 |
|
threadStarted.countDown(); |
508 |
|
done.await(); |
509 |
|
}}); |
510 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
510 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
511 |
|
assertEquals(TASKS, p.getTaskCount()); |
512 |
|
} finally { |
513 |
|
done.countDown(); |
579 |
|
threadStarted.countDown(); |
580 |
|
done.await(); |
581 |
|
}}); |
582 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
582 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
583 |
|
assertFalse(p.isTerminating()); |
584 |
|
done.countDown(); |
585 |
|
} finally { |
604 |
|
threadStarted.countDown(); |
605 |
|
done.await(); |
606 |
|
}}); |
607 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
607 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
608 |
|
assertFalse(p.isTerminating()); |
609 |
|
done.countDown(); |
610 |
|
} finally { |
632 |
|
}}; |
633 |
|
tasks[i] = p.schedule(r, 1, MILLISECONDS); |
634 |
|
} |
635 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
635 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
636 |
|
BlockingQueue<Runnable> q = p.getQueue(); |
637 |
|
assertTrue(q.contains(tasks[tasks.length - 1])); |
638 |
|
assertFalse(q.contains(tasks[0])); |
659 |
|
}}; |
660 |
|
tasks[i] = p.schedule(r, 1, MILLISECONDS); |
661 |
|
} |
662 |
< |
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
662 |
> |
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
663 |
|
BlockingQueue<Runnable> q = p.getQueue(); |
664 |
|
assertFalse(p.remove((Runnable)tasks[0])); |
665 |
|
assertTrue(q.contains((Runnable)tasks[4])); |