java中fork-join的原理解析
作者:darmi-大张 发布时间:2023-12-13 08:49:16
ForkJoinTask就是ForkJoinPool里面的每一个任务。他主要有两个子类:RecursiveAction和RecursiveTask。然后通过fork()方法去分配任务执行任务,通过join()方法汇总任务结果,
这就是整个过程的运用。他有两个子类,使用这两个子类都可以实现我们的任务分配和计算。
(1)RecursiveAction 一个递归无结果的ForkJoinTask(没有返回值)
(2)RecursiveTask 一个递归有结果的ForkJoinTask(有返回值)
ForkJoinPool:中含有一个workQueues队列;
workQueues:由ForkJoinTask数组和workerThread和指向ForkJoinPool的引用;
ForkJoinTask数组负责存放程序提交给ForkJoinPool的任务,而workerThread数组负责执行这些任务,ForkJoinPool的引用是为了当ForkJoinTask数组中的任务处理完之后再次获取任务交给workerThread进行处理。整个结构大致如下图:
知识点扩展:Java并发Fork-Join框架原理解析
1、什么是Foirk/Join框架
Fork/Join框架是Java7提供用于并行执行任务的框架,是一个把大任务分割成若干个小任务,最终汇总每个小任务结果后得到大任务结果的框架。
2、什么是并行流与顺序流2.1 什么是并行流?
并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流。
2.2 工作窃取模式
某个线程从其他队列里窃取任务来执行,
3、使用Fork/Join框架
/**
* 累加运算测试
*/
public class ForkJoinCalculate extends RecursiveTask<Long> {
/**
*
*/
private static final long serialVersionUID = 7125244951292834932L;
private long start;// 起始值
private long end;// 结束值
private static final long THRESHOLD = 10000L;// 临界值
@Override
protected Long compute() {
long length = end - start;
if(length <= THRESHOLD) {
long sum = 0L;
for (long i = start; i <= end; i++) {
sum += i;
}
return sum;
}else {
long middle = (start + end) / 2;// 中间值
ForkJoinCalculate left = new ForkJoinCalculate(start, middle);// 0-50000000
left.fork();// 拆分子任务,同时压入线程队列
ForkJoinCalculate right = new ForkJoinCalculate(middle + 1, end);// 50000001-100000000
right.fork();// 拆分子任务,同时压入线程队列
return left.join() + right.join();// 汇总任务结果
}
}
public ForkJoinCalculate() {
}
public ForkJoinCalculate(long start, long end) {
this.start = start;
this.end = end;
}
}
4、Java8中的并行流和顺序流
4.1顺序流
/**
* Java8的顺序流
*/
@Test
public void test3() {
Instant start = Instant.now();// java8中新时间日期API
LongStream.rangeClosed(0, 10000000000L)
.sequential()// 顺序流
.reduce(0, Long::sum);
Instant end = Instant.now();
// 5780
System.out.println("耗费时间为:" + Duration.between(start, end).toMillis());// java8中新时间日期API
}
4.2步行流
/**
* Java8的并行流
*/
@Test
public void test4() {
Instant start = Instant.now();// java8中新时间日期API
LongStream.rangeClosed(0, 10000000000L)
.parallel()// 并行流
.reduce(0, Long::sum);
Instant end = Instant.now();
// 2392
System.out.println("耗费时间为:" + Duration.between(start, end).toMillis());// java8中新时间日期API
}
来源:https://blog.csdn.net/qq_28175019/article/details/115680638
猜你喜欢
- 前导:发过程中经常会使用java将office系列文档转换为PDF, 一般都使用微软提供的openoffice+jodconverter 实
- 最近要做一个网站,要求实现验证码程序,经过不断调试,终于成功实现功能。一、验证码生成类生成验证码的话需要用到java的Graphics类库,
- 一本书的页码从自然数1开始顺序编码直到自然数n。书的页码按照通常的习惯编排,每个页码都不含多余的前导数字0。例如第6页用6表示而不是06或0
- Mybatis typeAlias标签在实际的工程之中,类的全限定名称很长,当我们需要大量使用的时候,这非常不方便的,然而mybatis提供
- 命令模式命令模式很好理解,举个例子,司令员下令让士兵去干件事情,从整个事情的角度来考虑,司令员的作用是,发出口令,口令经过传递,传到了士兵耳
- 背景今天面试字节算法岗时被问到的问题,让我用C++实现一个softmax函数。softmax是逻辑回归在多分类问题上的推广。大概的公式如下:
- 堆区:只存放类对象,线程共享;方法区:又叫静态存储区,存放class文件和静态数据,线程共享;栈区:存放方法局部变量,基本类型变量区、执行环
- 单选题:(每道题目2分)1. 下列哪个声明是错误的?(B) A. int i=10;B. float f=1.1;&
- 最近重新研究Java基础知识,发现以前太多知识知识略略带过了,比较说Java的线程机制,在Java中有两类线程:User Thread(用户
- 虽然说模块通信、路由协议在Android已经不新鲜了,但是如果脱离了那些优秀的开源库我们从零开始自己造一个库,有时候重复造轮子会让自己对所谓
- 一、HashMap初始化方法HashMap() 不带参数,默认初始化大小为16,加载因子为0.75;HashMap(int initialC
- 本文实例为大家分享了javaweb多文件上传及zip打包下载的具体代码,供大家参考,具体内容如下项目中经常会使用到文件上传及下载的功能。本篇
- 一,使用注解: 在spring的配置文件applicationContext.xml中,加入注解扫描。配
- 本文实例为大家分享了java实现双色球抽奖的具体代码,供大家参考,具体内容如下实现双色球先考虑整体思路:1.随机生成7位数的数组为大奖号码(
- 实例如下所示:/** * 创建多级目录文件 * * @param path 文件路径 * @throws IOException */pri
- 目录一,功能二,工具三、效果图:四、数据库设计五、JAVA层次分析六、主要Java代码分析一,功能管理员登录图书借阅信息管理图书信息管理管理
- 本文实例为大家分享了java实现人员信息管理系统的具体代码,供大家参考,具体内容如下实现增删改查.java入门的练手小程序1.Person类
- 目前常用的ORM框架有 Mybatis(batis)、MybatisPlus,Hibernate、Jpa等几个框架,今天就简单介绍一下搭建M
- 本文基于SpringBoot 2.5.0-M2讲解Spring中Lifecycle和SmartLifecycle的作用和区别,以及如何控制S
- MultiFrameImageStreamCompleterMultiFrameImageStreamCompleter 是一个可组合的 I