# | Line 1257 | Line 1257 | public class ThreadPoolExecutorSubclassT | |
---|---|---|
1257 | ThreadPoolExecutor p = new CustomTPE(1,1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(1), h); | |
1258 | ||
1259 | try { p.shutdown(); } catch (SecurityException ok) { return; } | |
1260 | < | try { |
1260 | > | try (PoolCleaner cleaner = cleaner(p)) { |
1261 | TrackedNoOpRunnable r = new TrackedNoOpRunnable(); | |
1262 | p.execute(r); | |
1263 | assertFalse(r.done); | |
1264 | – | } finally { |
1265 | – | joinPool(p); |
1264 | } | |
1265 | } | |
1266 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |