13 |
|
import java.util.concurrent.ExecutionException; |
14 |
|
import java.util.concurrent.ForkJoinPool; |
15 |
|
import java.util.concurrent.ForkJoinTask; |
16 |
+ |
import java.util.concurrent.ThreadLocalRandom; |
17 |
|
import java.util.concurrent.TimeoutException; |
18 |
|
import java.util.concurrent.atomic.AtomicInteger; |
19 |
|
import java.util.concurrent.atomic.AtomicReference; |
211 |
|
final AtomicInteger onCompletionN = new AtomicInteger(0); |
212 |
|
final AtomicInteger onExceptionalCompletionN = new AtomicInteger(0); |
213 |
|
final AtomicInteger setRawResultN = new AtomicInteger(0); |
214 |
< |
final AtomicReference<Object> rawResult = new AtomicReference<Object>(null); |
214 |
> |
final AtomicReference<Object> rawResult = new AtomicReference<>(null); |
215 |
|
int computeN() { return computeN.get(); } |
216 |
|
int onCompletionN() { return onCompletionN.get(); } |
217 |
|
int onExceptionalCompletionN() { return onExceptionalCompletionN.get(); } |