8 |
|
import java.util.concurrent.CancellationException; |
9 |
|
import java.util.concurrent.ExecutionException; |
10 |
|
import java.util.concurrent.ForkJoinPool; |
11 |
+ |
import java.util.concurrent.ForkJoinTask; |
12 |
|
import java.util.concurrent.ForkJoinWorkerThread; |
13 |
|
import java.util.concurrent.RecursiveTask; |
14 |
|
import java.util.concurrent.TimeUnit; |
60 |
|
assertNull(a.getException()); |
61 |
|
assertNull(a.getRawResult()); |
62 |
|
|
63 |
< |
if (! (Thread.currentThread() instanceof ForkJoinWorkerThread)) { |
63 |
> |
if (! ForkJoinTask.inForkJoinPool()) { |
64 |
|
Thread.currentThread().interrupt(); |
65 |
|
try { |
66 |
|
a.get(); |