JDK中的ForkJoin机制

2024-02-10 12:32
文章标签 jdk 机制 forkjoin

本文主要是介绍JDK中的ForkJoin机制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

ForkJoin的原理

ForkJoin的核心思想是分而治之。分而治之是指将一个大任务拆分(fork)成若干个小任务,分别计算每个小任务,得到结果,再将所有小任务的结果执行汇总(join),得到最终结果。当然,也不是说随便就能拆分的,要求小任务互相独立且与大任务形式相同。JDK为我们提供了ForkJoin机制,我们不需要考虑线程调度问题(比如:使用ForkJoinPool),也不需要考虑任务的拆分和结果的汇总(比如:使用ForkjoinTask等),只需要考虑业务实现。

过程图解

工作密取

当前线程的任务完成后,会自动获取其他线程未完成的任务进行执行,如下图中所示,假设某个大任务总共拆分成了8个任务,由两个线程执行,当线程1执行完任务1/2/3/4时,线程2才刚好开始执行任务7(或者任务5/6),这个时候线程1就会从线程2的任务队列末尾拿到任务8并执行,将执行结果放回到线程2的任务队列中,这样能够减少线程阻塞或者闲置的时间,提高CPU利用率,提高性能。

任务拆分和结果汇总

JDK中提供了专门的类完成任务拆分和结果汇总的操作。比如ForkjoinTask类,但是我们通常并不是直接继承这个类,而是直接继承其子类——RecursiveAction和RecursiveTask。RecursiveAction,用于没有返回结果的任务;RecursiveTask,用于有返回结果的任务。

ForkJoin的使用流程

1)、创建一个ForkJoinPool,用来执行任务;

2)、创建一个任务(业务逻辑),建议继承RecursiveAction和RecursiveTask,不建议继承ForkjoinTask;

3)、使用ForkJoinPool的执行方法:invoke/execute/submit,其中invoke方法是同步方法,execute/submit是异步方法,execute无返回值,submit有返回值;

4)、如果第3步中使用invoke,可以直接获得结果;如果使用execute,没有结果返回;如果使用submit,可以在方法中使用join对结果汇总,使用get方法获取结果。

 

 

如果有写的不对的地方,请大家多多批评指正,非常感谢!

这篇关于JDK中的ForkJoin机制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/697106

相关文章

嵌入式Linux驱动中的异步通知机制详解

《嵌入式Linux驱动中的异步通知机制详解》:本文主要介绍嵌入式Linux驱动中的异步通知机制,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、异步通知的核心概念1. 什么是异步通知2. 异步通知的关键组件二、异步通知的实现原理三、代码示例分析1. 设备结构

JVM垃圾回收机制之GC解读

《JVM垃圾回收机制之GC解读》:本文主要介绍JVM垃圾回收机制之GC,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、死亡对象的判断算法1.1 引用计数算法1.2 可达性分析算法二、垃圾回收算法2.1 标记-清除算法2.2 复制算法2.3 标记-整理算法2.4

C++如何通过Qt反射机制实现数据类序列化

《C++如何通过Qt反射机制实现数据类序列化》在C++工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作,所以本文就来聊聊C++如何通过Qt反射机制实现数据类序列化吧... 目录设计预期设计思路代码实现使用方法在 C++ 工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作。由于数据类

如何在Mac上安装并配置JDK环境变量详细步骤

《如何在Mac上安装并配置JDK环境变量详细步骤》:本文主要介绍如何在Mac上安装并配置JDK环境变量详细步骤,包括下载JDK、安装JDK、配置环境变量、验证JDK配置以及可选地设置PowerSh... 目录步骤 1:下载JDK步骤 2:安装JDK步骤 3:配置环境变量1. 编辑~/.zshrc(对于zsh

SpringRetry重试机制之@Retryable注解与重试策略详解

《SpringRetry重试机制之@Retryable注解与重试策略详解》本文将详细介绍SpringRetry的重试机制,特别是@Retryable注解的使用及各种重试策略的配置,帮助开发者构建更加健... 目录引言一、SpringRetry基础知识二、启用SpringRetry三、@Retryable注解

SpringKafka错误处理(重试机制与死信队列)

《SpringKafka错误处理(重试机制与死信队列)》SpringKafka提供了全面的错误处理机制,通过灵活的重试策略和死信队列处理,下面就来介绍一下,具有一定的参考价值,感兴趣的可以了解一下... 目录引言一、Spring Kafka错误处理基础二、配置重试机制三、死信队列实现四、特定异常的处理策略五

Linux系统中卸载与安装JDK的详细教程

《Linux系统中卸载与安装JDK的详细教程》本文详细介绍了如何在Linux系统中通过Xshell和Xftp工具连接与传输文件,然后进行JDK的安装与卸载,安装步骤包括连接Linux、传输JDK安装包... 目录1、卸载1.1 linux删除自带的JDK1.2 Linux上卸载自己安装的JDK2、安装2.1

Linux卸载自带jdk并安装新jdk版本的图文教程

《Linux卸载自带jdk并安装新jdk版本的图文教程》在Linux系统中,有时需要卸载预装的OpenJDK并安装特定版本的JDK,例如JDK1.8,所以本文给大家详细介绍了Linux卸载自带jdk并... 目录Ⅰ、卸载自带jdkⅡ、安装新版jdkⅠ、卸载自带jdk1、输入命令查看旧jdkrpm -qa

java中反射(Reflection)机制举例详解

《java中反射(Reflection)机制举例详解》Java中的反射机制是指Java程序在运行期间可以获取到一个对象的全部信息,:本文主要介绍java中反射(Reflection)机制的相关资料... 目录一、什么是反射?二、反射的用途三、获取Class对象四、Class类型的对象使用场景1五、Class

JDK多版本共存并自由切换的操作指南(本文为JDK8和JDK17)

《JDK多版本共存并自由切换的操作指南(本文为JDK8和JDK17)》本文介绍了如何在Windows系统上配置多版本JDK(以JDK8和JDK17为例),并通过图文结合的方式给大家讲解了详细步骤,具有... 目录第一步 下载安装JDK第二步 配置环境变量第三步 切换JDK版本并验证可能遇到的问题前提:公司常