summaryrefslogtreecommitdiff
path: root/jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
diff options
context:
space:
mode:
authorPrzemyslaw Szczepaniak <pszczepaniak@google.com>2016-03-15 09:42:19 +0000
committerPrzemyslaw Szczepaniak <pszczepaniak@google.com>2016-03-15 09:42:19 +0000
commited4f365789d43b1961657195df223a19bf4ef20f (patch)
tree214d4e0cdccf19471194d03dd3172933336910f1 /jsr166-tests/src/test/java/jsr166/RecursiveActionTest.java
parent5328e07d282bef36ac8b757bbee16a761415b2c4 (diff)
Revert "JSR-166 update"
I missed comments on framework/base change regarding "@since 9" parts This reverts commit 5328e07d282bef36ac8b757bbee16a761415b2c4. Change-Id: Iff71b8a17e79a0a5c1ecadc05bccadceabb83393
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);
}
/**