本篇内容介绍了“java Fork/Join框架的使用方法”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
Fork/Join框架重点说明：
1，在必要的情况下，将一个大任务，进行拆分（fork） 成若干个子任务（拆到不能再拆，这里就是指我们制定的拆分的临界值），再将一个个小任务的结果进行join汇总。
2，Fork/Join采用“工作窃取模式”。
3，ForkJoin更有效的利用的CPU资源。
4，Java 8 中将并行流进行了优化，Stream API可以声明性的通过parallel()与sequential()在并行流与串行流中随意切换。
以下是简单示例：
public class ForkJoinWorkTest extends RecursiveTask<Long> {
private Long start;
private Long end;
public static final Long critical = 100000L;
public ForkJoinWorkTest(Long start, Long end) {
this.start = start;
this.end = end;
}
@Override
protected Long compute() {
Long length = end - start;
if(length <= critical) {
// 拆分完毕
Long sum = 0L;
for(Long i = start; i <= end; i++) {
sum += i;
}
return sum;
} else {
// 未拆分完毕
Long middle = (end + start)/2;
ForkJoinWorkTest right = new ForkJoinWorkTest(start, middle);
right.fork();
ForkJoinWorkTest left = new ForkJoinWorkTest(middle + 1, end);
left.fork();
return right.join() + left.join();
}
}
}单元测试代码：
import java.util.concurrent.*;
import java.util.stream.LongStream;
public class ForkJoinWorkTestDemo {
public static void main(String args[]) {
Long startTime = System.currentTimeMillis();
ForkJoinPool forkJoinPool = new ForkJoinPool();
ForkJoinTask<Long> forkJoinTask = new ForkJoinWorkTest(0L,100000000L);
Long invoke = forkJoinPool.invoke(forkJoinTask);
Long endTime = System.currentTimeMillis();
System.out.println("forkAndJoin:"+invoke+" time:"+(endTime - startTime));
System.out.println("=======================================================");
Long startTime1 = System.currentTimeMillis();
Long sum = 0L;
for(Long i=0L;i<=100000000L;i++) {
sum += i;
}
Long endTime1 = System.currentTimeMillis();
System.out.println("normalSum:"+sum+" time:"+(endTime1 - startTime1));
System.out.println("=======================================================");
Long startTime2 = System.currentTimeMillis();
Long sum8 = LongStream.rangeClosed(0, 100000000L).parallel().reduce(0,Long::sum);
Long endTime2 = System.currentTimeMillis();
System.out.println("Jdk8Sum:"+sum8+" time:"+(endTime2 - startTime2));
}
}结果如下：
“java Fork/Join框架的使用方法”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注天达云网站，小编将为大家输出更多高质量的实用文章！