Java并发编程之Fork/Join框架的理解
作者：小志的博客
今天带大家学习Java并发编程的相关知识,文中对Fork/Join框架作了非常详细的介绍,对正在学习有关知识的小伙伴们很有帮助,需要的朋友可以参考下
一、Fork/Join框架的理解
- ForkJoinTask类属于java.util.concurrent 包下；
- ForkJoinTask类下有2个子类，分别为RecursiveTask和RecursiveAction类；（lz示例中使用RecursiveTask类进行重写compute()方法进行实现数值的累加计算）
- ForkJoinTask类 将一个大的任务拆分成多个子任务进行并行处理，最后将子任务结果合并成最后的计算结果，并进行输出。
二、Fork/Join框架使用示例
示例场景：对数值进行累加计算；
注：示例中使用ForkJoinTask类的子类(RecursiveTask类)进行重写compute()方法进行实现数值的累加计算
1、代码
package com.xz.thread.ForkJoin;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
/**
* @description:
* @author: xz
* @create: 2021-06-06 17:15
*/
public class Demo extends RecursiveTask<Integer> {
private int start;//子任务开始计算的开始值
private int end;//子任务开始计算的结束值
private static final Integer MAX_VALUE = 50;
//构造方法
public Demo(int start, int end) {
this.start = start;
this.end = end;
}
//计算
@Override
protected Integer compute() {
int sum =0;
//如果所需要计算的数值拆分为足够小，则进行累加计算
if(end-start <= MAX_VALUE){
System.out.println("startValue = " + start + ";endValue = " + end);
for(int i=start;i<=end;i++){
sum +=i;
}
}else{//否则再进行任务拆分,拆分成2个子任务
Demo d1 = new Demo(start, (start + end) / 2);
Demo d2 = new Demo((start + end) / 2, end);
//执行2个子任务
d1.fork();
d2.fork();
//合并子任务
Integer value1= d1.join();
Integer value2= d2.join();
sum =value1+value2;
}
return sum;
}
//测试
public static void main(String[] args) throws Exception{
//ForkJoinPool主要用于实现“分而治之”的算法，特别是分治之后递归调用的函数
ForkJoinPool forkJoinPool = new ForkJoinPool();
//提交一个ForkJoinTask执行
ForkJoinTask<Integer> forkJoinTask = forkJoinPool.submit(new Demo(1,200));
System.out.println("计算结果="+forkJoinTask.get());
}
}
2、运行测方法，输出如下：
3、结论：
由第2步骤的输出结果可知，先把1到200的所有数值进行任务拆分（上图拆分成了4部分）,然后再将所有子任务结的果合并成最后的计算结果
到此这篇关于Java并发编程之Fork/Join框架的理解的文章就介绍到这了,更多相关Fork/Join框架的理解内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！