18 |
|
import java.util.concurrent.Future; |
19 |
|
import java.util.concurrent.RejectedExecutionException; |
20 |
|
import java.util.concurrent.RunnableFuture; |
21 |
– |
import java.util.concurrent.ThreadLocalRandom; |
21 |
|
import java.util.concurrent.TimeUnit; |
22 |
|
|
23 |
|
/** |
530 |
|
* Returns a new worker thread operating in the given pool. |
531 |
|
* |
532 |
|
* @param pool the pool this thread works in |
534 |
– |
* @throws NullPointerException if the pool is null |
533 |
|
* @return the new worker thread |
534 |
+ |
* @throws NullPointerException if the pool is null |
535 |
|
*/ |
536 |
|
public ForkJoinWorkerThread newThread(ForkJoinPool pool); |
537 |
|
} |
3281 |
|
ForkJoinWorkerThreadFactory factory |
3282 |
|
= defaultForkJoinWorkerThreadFactory; |
3283 |
|
UncaughtExceptionHandler handler = null; |
3284 |
< |
try { // ignore exceptions in accesing/parsing properties |
3284 |
> |
try { // ignore exceptions in accessing/parsing properties |
3285 |
|
String pp = System.getProperty |
3286 |
|
("java.util.concurrent.ForkJoinPool.common.parallelism"); |
3287 |
|
String fp = System.getProperty |