本篇内容介绍了“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{ 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 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框架的使用方法”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！
