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 {

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 = neBBURqw 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 suBBURqm;

}

//测试

public static void main(String[] args) throws Exception{

//ForkJoinPool主要用于实现“分而治之”的算法，特别是分治之后递归调用的函数

ForkJoinPool forkJoinPool = new ForkJoinPool();

//提交一个ForkJoinTask执行

ForkJoinTask forkJoinTask = forkJoinPool.submit(new Demo(1,200));

System.out.println("计算结果="+forkJoinTask.get());

}

}

2、运行测方法，输出如下：

3、结论：

由第2步骤的输出结果可知，先把1到200的所有数值进行任务拆分（上图拆分成了4部分）,然后再将所有子任务结的果合并成最后的计算结果

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。