diff options
Diffstat (limited to 'jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java')
-rw-r--r-- | jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java b/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java index 77833703d0..2c07c2a2f8 100644 --- a/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java +++ b/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java @@ -28,7 +28,7 @@ public class RecursiveTaskTest extends JSR166TestCase { // main(suite(), args); // } // public static Test suite() { - // return new TestSuite(...); + // return new TestSuite(RecursiveTaskTest.class); // } private static ForkJoinPool mainPool() { @@ -46,15 +46,13 @@ public class RecursiveTaskTest extends JSR166TestCase { } private <T> T testInvokeOnPool(ForkJoinPool pool, RecursiveTask<T> a) { - try { + try (PoolCleaner cleaner = cleaner(pool)) { checkNotDone(a); T result = pool.invoke(a); checkCompletedNormally(a, result); return result; - } finally { - joinPool(pool); } } @@ -335,6 +333,8 @@ public class RecursiveTaskTest extends JSR166TestCase { FibTask f = new FibTask(8); assertSame(f, f.fork()); helpQuiesce(); + while (!f.isDone()) // wait out race + ; assertEquals(0, getQueuedTaskCount()); checkCompletedNormally(f, 21); return NoResult; |