Fork/Join池没有一个最大线程数，只有一个期望并发数，指我们希望同时又多少活跃的线程，通常默认值即运行时计算机处理器的数量-1，可以通过如下方式来显示的调整。
-Djava.util.concurrent.ForkJoinPool.common.parallelism=N
System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "20");
大的任务分割成互不依赖的子任务，减少线程竞争，将任务放在不同的队列。 每个线程维护一个双端队列，线程自己队列任务完成之后，可以从其他线程里面窃取任务，被窃取线程从头部获取任务，窃取线程从队列尾部获取任务。
判断一个数是否为质数
// 要计算的质数
primeNumber = new BigInteger(sPrime);
// 对质数进行求平方根
sqrt = Utils.sqrt(primeNumber);
// 线程数 ForkJoinPoll开启worker线程数
numberOfThread = new BigInteger(sNumberOfThread);
// 给每个线程分配的块
lengthForThread = TestPrime.sqrt.divide(numberOfThread);
//
Set<BigInteger> collect = Stream
.iterate(Utils.two, n -> n.add(TestPrime.lengthForThread))
.limit(TestPrime.numberOfThread.longValue())
.parallel()
.filter(i -> Utils.primeProcessPart(i))
.collect(Collectors.toSet());
//
public static Boolean primeProcessPart(BigInteger from) {
boolean isPrime = true;
BigInteger to = from.add(TestPrime.lengthForThread);
for (BigInteger i = from; i.compareTo(to) <= 0; i = i
.add(BigInteger.ONE)) {
if (TestPrime.primeNumber.mod(i).equals(BigInteger.ZERO)) {
isPrime = false;
}
}
return isPrime;
}