summaryrefslogtreecommitdiff
path: root/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java')
-rw-r--r--jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java10
1 files changed, 6 insertions, 4 deletions
diff --git a/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java b/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
index c8e33beb20..1c3bba8418 100644
--- a/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
+++ b/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
@@ -32,7 +32,7 @@ public class RecursiveActionTest extends JSR166TestCase {
// main(suite(), args);
// }
// public static Test suite() {
- // return new TestSuite(RecursiveActionTest.class);
+ // return new TestSuite(...);
// }
private static ForkJoinPool mainPool() {
@@ -50,12 +50,14 @@ public class RecursiveActionTest extends JSR166TestCase {
}
private void testInvokeOnPool(ForkJoinPool pool, RecursiveAction a) {
- try (PoolCleaner cleaner = cleaner(pool)) {
+ try {
checkNotDone(a);
assertNull(pool.invoke(a));
checkCompletedNormally(a);
+ } finally {
+ joinPool(pool);
}
}
@@ -427,12 +429,12 @@ public class RecursiveActionTest extends JSR166TestCase {
t = newStartedThread(r);
testInvokeOnPool(mainPool(), a);
- awaitTermination(t);
+ awaitTermination(t, LONG_DELAY_MS);
a.reinitialize();
t = newStartedThread(r);
testInvokeOnPool(singletonPool(), a);
- awaitTermination(t);
+ awaitTermination(t, LONG_DELAY_MS);
}
/**