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