234 |
|
new CustomTPE(1, 1, |
235 |
|
2 * LONG_DELAY_MS, MILLISECONDS, |
236 |
|
new ArrayBlockingQueue<Runnable>(10)); |
237 |
< |
try (PoolCleaner<ThreadPoolExecutor> cleaner = cleaner(p)) { |
237 |
> |
try (PoolCleaner cleaner = cleaner(p)) { |
238 |
|
final CountDownLatch done = new CountDownLatch(1); |
239 |
|
final Runnable task = new CheckedRunnable() { |
240 |
|
public void realRun() { done.countDown(); }}; |
254 |
|
new ArrayBlockingQueue<Runnable>(10)); |
255 |
|
final CountDownLatch threadStarted = new CountDownLatch(1); |
256 |
|
final CountDownLatch done = new CountDownLatch(1); |
257 |
< |
try { |
257 |
> |
try (PoolCleaner cleaner = cleaner(p)) { |
258 |
|
assertEquals(0, p.getActiveCount()); |
259 |
|
p.execute(new CheckedRunnable() { |
260 |
|
public void realRun() throws InterruptedException { |
264 |
|
}}); |
265 |
|
assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
266 |
|
assertEquals(1, p.getActiveCount()); |
267 |
– |
} finally { |
267 |
|
done.countDown(); |
269 |
– |
joinPool(p); |
268 |
|
} |
269 |
|
} |
270 |
|
|