# | Line 41 | Line 41 | public class RecursiveTaskTest extends J | |
---|---|---|
41 | } | |
42 | ||
43 | private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { | |
44 | < | try { |
44 | > | try (PoolCleaner cleaner = cleaner(pool)) { |
45 | checkNotDone(a); | |
46 | ||
47 | T result = pool.invoke(a); | |
48 | ||
49 | checkCompletedNormally(a, result); | |
50 | return result; | |
51 | – | } finally { |
52 | – | joinPool(pool); |
51 | } | |
52 | } | |
53 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |