summaryrefslogtreecommitdiff
path: root/jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java
diff options
context:
space:
mode:
authorPrzemyslaw Szczepaniak <pszczepaniak@google.com>2016-03-11 15:59:10 +0000
committerPrzemyslaw Szczepaniak <pszczepaniak@google.com>2016-03-14 15:40:14 +0000
commit5328e07d282bef36ac8b757bbee16a761415b2c4 (patch)
treed7fd9980442e0d647e1454f54f3d037f4b2280e7 /jsr166-tests/src/test/java/jsr166/RecursiveTaskTest.java
parent8d28fc1d531b4b39def9598de89311aff112f955 (diff)
JSR-166 update
Adapted from sources taken from CVS using: cvs -d ':pserver:anonymous@gee.cs.oswego.edu/home/jsr166/jsr166' checkout -D "03/03/2016 10:00:00 GMT" jsr166 Bug: 27426599 Change-Id: Ic9ba278929f8747d58b69e7d67ec325064588bff
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;