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

相关文章

Spring排序机制之接口与注解的使用方法

《Spring排序机制之接口与注解的使用方法》本文介绍了Spring中多种排序机制,包括Ordered接口、PriorityOrdered接口、@Order注解和@Priority注解,提供了详细示例... 目录一、Spring 排序的需求场景二、Spring 中的排序机制1、Ordered 接口2、Pri

MySQL 缓存机制与架构解析(最新推荐)

《MySQL缓存机制与架构解析(最新推荐)》本文详细介绍了MySQL的缓存机制和整体架构,包括一级缓存(InnoDBBufferPool)和二级缓存(QueryCache),文章还探讨了SQL... 目录一、mysql缓存机制概述二、MySQL整体架构三、SQL查询执行全流程四、MySQL 8.0为何移除查

一文详解Java Condition的await和signal等待通知机制

《一文详解JavaCondition的await和signal等待通知机制》这篇文章主要为大家详细介绍了JavaCondition的await和signal等待通知机制的相关知识,文中的示例代码讲... 目录1. Condition的核心方法2. 使用场景与优势3. 使用流程与规范基本模板生产者-消费者示例

java脚本使用不同版本jdk的说明介绍

《java脚本使用不同版本jdk的说明介绍》本文介绍了在Java中执行JavaScript脚本的几种方式,包括使用ScriptEngine、Nashorn和GraalVM,ScriptEngine适用... 目录Java脚本使用不同版本jdk的说明1.使用ScriptEngine执行javascript2.

一文带你理解Python中import机制与importlib的妙用

《一文带你理解Python中import机制与importlib的妙用》在Python编程的世界里,import语句是开发者最常用的工具之一,它就像一把钥匙,打开了通往各种功能和库的大门,下面就跟随小... 目录一、python import机制概述1.1 import语句的基本用法1.2 模块缓存机制1.

Redis主从/哨兵机制原理分析

《Redis主从/哨兵机制原理分析》本文介绍了Redis的主从复制和哨兵机制,主从复制实现了数据的热备份和负载均衡,而哨兵机制可以监控Redis集群,实现自动故障转移,哨兵机制通过监控、下线、选举和故... 目录一、主从复制1.1 什么是主从复制1.2 主从复制的作用1.3 主从复制原理1.3.1 全量复制

Redis缓存问题与缓存更新机制详解

《Redis缓存问题与缓存更新机制详解》本文主要介绍了缓存问题及其解决方案,包括缓存穿透、缓存击穿、缓存雪崩等问题的成因以及相应的预防和解决方法,同时,还详细探讨了缓存更新机制,包括不同情况下的缓存更... 目录一、缓存问题1.1 缓存穿透1.1.1 问题来源1.1.2 解决方案1.2 缓存击穿1.2.1

Java如何通过反射机制获取数据类对象的属性及方法

《Java如何通过反射机制获取数据类对象的属性及方法》文章介绍了如何使用Java反射机制获取类对象的所有属性及其对应的get、set方法,以及如何通过反射机制实现类对象的实例化,感兴趣的朋友跟随小编一... 目录一、通过反射机制获取类对象的所有属性以及相应的get、set方法1.遍历类对象的所有属性2.获取

MySQL中的锁和MVCC机制解读

《MySQL中的锁和MVCC机制解读》MySQL事务、锁和MVCC机制是确保数据库操作原子性、一致性和隔离性的关键,事务必须遵循ACID原则,锁的类型包括表级锁、行级锁和意向锁,MVCC通过非锁定读和... 目录mysql的锁和MVCC机制事务的概念与ACID特性锁的类型及其工作机制锁的粒度与性能影响多版本

Spring使用@Retryable实现自动重试机制

《Spring使用@Retryable实现自动重试机制》在微服务架构中,服务之间的调用可能会因为一些暂时性的错误而失败,例如网络波动、数据库连接超时或第三方服务不可用等,在本文中,我们将介绍如何在Sp... 目录引言1. 什么是 @Retryable?2. 如何在 Spring 中使用 @Retryable