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(); |
603 |
|
return NoResult; |
604 |
|
} |
605 |
|
}; |
606 |
< |
a.invoke(); |
606 |
> |
assertSame(NoResult, a.invoke()); |
607 |
|
} |
608 |
|
|
609 |
|
/** |