1018 |
|
60, SECONDS, |
1019 |
|
new ArrayBlockingQueue<Runnable>(10)); |
1020 |
|
|
1021 |
< |
final CountDownLatch threadStarted = new CountDownLatch(1); |
1022 |
< |
final CountDownLatch done = new CountDownLatch(1); |
1023 |
< |
try { |
1021 |
> |
try (PoolCleaner cleaner = cleaner(p)) { |
1022 |
> |
final CountDownLatch threadStarted = new CountDownLatch(1); |
1023 |
> |
final CountDownLatch done = new CountDownLatch(1); |
1024 |
|
Thread t = newStartedThread(new CheckedInterruptedRunnable() { |
1025 |
|
public void realRun() throws Exception { |
1026 |
|
Callable task = new CheckedCallable<Boolean>() { |
1035 |
|
assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
1036 |
|
t.interrupt(); |
1037 |
|
awaitTermination(t, MEDIUM_DELAY_MS); |
1038 |
– |
} finally { |
1038 |
|
done.countDown(); |
1040 |
– |
joinPool(p); |
1039 |
|
} |
1040 |
|
} |
1041 |
|
|