summaryrefslogtreecommitdiff
path: root/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java
diff options
context:
space:
mode:
authorPrzemyslaw Szczepaniak <pszczepaniak@google.com>2016-03-15 09:37:42 +0000
committerGerrit Code Review <noreply-gerritcodereview@google.com>2016-03-15 09:37:42 +0000
commit37f9fec54f50b2e0898ee2b61d058c4de879e38b (patch)
treed7fd9980442e0d647e1454f54f3d037f4b2280e7 /jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java
parent8d28fc1d531b4b39def9598de89311aff112f955 (diff)
parent5328e07d282bef36ac8b757bbee16a761415b2c4 (diff)
Merge "JSR-166 update"
Diffstat (limited to 'jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java')
-rw-r--r--jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java8
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;