Java并发编程之Fork/Join框架的理解
作者:小志的博客 时间:2023-09-30 14:14:01
一、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部分),然后再将所有子任务结的果合并成最后的计算结果
来源:https://wwwxz.blog.csdn.net/article/details/117636005
标签:java,Fork,Join,框架
0
投稿
猜你喜欢
详解Spring Boot Oauth2缓存UserDetails到Ehcache
2023-02-26 21:57:12
Java字符串拼接详解
2022-10-17 06:22:51
Spring Security使用Lambda DSL配置流程详解
2021-12-23 19:20:32
Jenkins初级应用之Invoke Phing targets插件配置
2023-10-14 03:55:56
android实现图片闪烁动画效果的两种实现方式(实用性高)
2022-06-29 14:18:32
详解SpringMVC使用MultipartFile实现文件的上传
2023-03-28 00:48:18
Android实现app应用多语言切换功能
2023-03-30 20:47:13
C#正则表达式实用大全(建议收藏!)
2023-08-29 20:23:58
SpringBoot配置及使用Schedule过程解析
2021-12-31 18:47:32
解决persistence.xml配置文件修改存放路径的问题
2023-07-16 09:53:54
C#操作 JSON方法汇总
2023-01-23 06:49:59
SpringBoot如何整合redis实现过期key监听事件
2023-08-04 18:51:19
maven为MANIFEST.MF文件添加内容的方法
2022-10-29 11:15:56
SpringBoot打包发布到linux上(centos 7)的步骤
2023-08-11 06:35:55
Java多线程编程之读写锁ReadWriteLock用法实例
2021-10-13 17:01:14
java 读取本地文件实例详解
2023-08-12 20:41:32
Java中的字节流文件读取教程(一)
2023-08-14 08:14:47
Android判断网络类型的方法(2g,3g还是wifi)
2023-09-15 10:53:23
unity里获取text中文字宽度并截断省略的操作
2023-11-02 07:48:52
Android线程中Handle的使用讲解
2023-04-04 17:43:56