【并发编程篇】详解Forkjoin

2024-01-13 14:12
文章标签 详解 并发 编程 forkjoin

本文主要是介绍【并发编程篇】详解Forkjoin,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

  • 🍔什么是Forkjoin
  • 🎈Forkjoin的方法
  • 🎆代码实现

在这里插入图片描述

🍔什么是Forkjoin

Fork/Join 是一种在多线程领域中常用的算法或技术,它的核心思想是将大任务分割成若干个小任务,然后将这些小任务分配给多个线程并行处理,最终将结果合并起来。这种思想可以应用于多种场景,例如图像处理、批处理、并行排序等。

在 Java 中,Fork/Join 这种思想被封装在了 java.util.concurrent 包中的 ForkJoinPool 类和 RecursiveTask 类中。ForkJoinPool 类是一个线程池,用于管理多个线程的执行,而 RecursiveTask 类则是一个抽象类,用于定义可分解的任务。通过使用这些类,开发者可以非常方便地实现 Fork/Join 的并行计算功能,从而提高应用程序的性能和效率。

总之,Fork/Join 并不是一个框架,而是一种并发编程技术,它可以帮助开发者实现高效的并行计算,并发挥多核 CPU 的计算能力。

🎈Forkjoin的方法

Fork/Join 框架提供了一些核心的方法来支持任务的分解和合并,下面我会对这些方法进行理论讲解:

  • fork() 方法:fork() 方法用于将当前任务进行分解,将其拆分成更小的子任务并提交给 Fork/Join 框架进行并行处理。该方法会异步地启动一个新的子任务,并立即返回,不会阻塞当前线程。
  • join() 方法:join() 方法用于等待子任务的执行完成,并获取其结果。在调用 join() 方法之前,程序会阻塞当前线程,直到子任务的执行完成。如果子任务还没有完成,则当前线程会暂停执行,转而执行其他可执行任务,从而实现工作窃取的效果。
  • invoke() 方法:invoke() 方法用于提交一个任务给 Fork/Join 框架进行处理,并返回任务的执行结果。该方法会同步地启动一个任务,并阻塞当前线程,直到任务执行完成并返回结果。这个方法通常用于提交根任务或最顶层的任务。
  • RecursiveTask 类和 RecursiveAction 类:Fork/Join 框架提供了两个抽象类 RecursiveTask 和 RecursiveAction,用于定义可分解的任务。RecursiveTask 适用于需要返回结果的任务,而 RecursiveAction 适用于不需要返回结果的任务。这两个类都有一个抽象方法 compute(),我们需要在子类中实现该方法来定义具体的任务逻辑。
  • Work-Stealing(工作窃取):Fork/Join 框架采用了工作窃取算法,使得线程在处理完自己的任务后可以从其他线程的队列中偷取任务来执行。这种方式可以提高并行计算的效率和负载均衡性能。工作窃取是通过双端队列实现的,每个线程都有自己的任务队列,当一个线程完成自己队列中的任务后,它会尝试从其他线程的队列末尾窃取任务来执行。

这些方法和概念是 Fork/Join 框架中非常重要的部分,它们通过任务的分解、合并和工作窃取机制,实现了高效的并行计算。理解并熟练使用这些方法可以帮助开发者更好地利用 Fork/Join 框架来处理并行计算任务。

🎆代码实现

ForkjoinDemo.java

package org.Test6;import java.util.concurrent.RecursiveTask;public class ForkjoinDemo extends RecursiveTask<Long> {private Long start; // 1private Long end; // 1990900000// 临界值private Long temp = 10000L;public ForkjoinDemo(Long start, Long end) {this.start = start;this.end = end;}// 计算方法@Overrideprotected Long compute() {if ((end - start) < temp) {Long sum = 0L;for (Long i = start; i <= end; i++) {sum += i;}return sum;} else { // forkjoin 递归long middle = (start + end) / 2; // 中间值ForkjoinDemo task1 = new ForkjoinDemo(start, middle);task1.fork(); // 拆分任务,把任务压入线程队列ForkjoinDemo task2 = new ForkjoinDemo(middle + 1, end);task2.fork(); // 拆分任务,把任务压入线程队列return task1.join() + task2.join();}}
}

Test.java

package org.Test6;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
import java.util.stream.LongStream;public class Test {public static void test1() {Long sum = 0L;long start = System.currentTimeMillis();for (Long i = 1L; i <= 10_0000_0000; i++) {sum += i;}long end = System.currentTimeMillis();System.out.println("sum=" + sum + " 时间:" + (end - start));}// 会使用ForkJoinpublic static void test2() throws ExecutionException, InterruptedException {long start = System.currentTimeMillis();ForkJoinPool forkJoinPool = new ForkJoinPool();ForkJoinTask<Long> task = new ForkjoinDemo(0L, 10_0000_0000L);ForkJoinTask<Long> submit = forkJoinPool.submit(task);// 提交任务Long sum = submit.get();long end = System.currentTimeMillis();System.out.println("sum=" + sum + " 时间:" + (end - start));}public static void test3() {long start = System.currentTimeMillis();// Stream并行流long sum = LongStream.rangeClosed(0L, 10_0000_0000L).parallel().reduce(0, Long::sum);long end = System.currentTimeMillis();System.out.println("sum=" + sum + " 时间:" + (end - start));}public static void main(String[] args) throws ExecutionException, InterruptedException {test1();test2();test3();}}

在这里插入图片描述

在技术的道路上,我们不断探索、不断前行,不断面对挑战、不断突破自我。科技的发展改变着世界,而我们作为技术人员,也在这个过程中书写着自己的篇章。让我们携手并进,共同努力,开创美好的未来!愿我们在科技的征途上不断奋进,创造出更加美好、更加智能的明天!

在这里插入图片描述

这篇关于【并发编程篇】详解Forkjoin的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

mybatis执行insert返回id实现详解

《mybatis执行insert返回id实现详解》MyBatis插入操作默认返回受影响行数,需通过useGeneratedKeys+keyProperty或selectKey获取主键ID,确保主键为自... 目录 两种方式获取自增 ID:1. ​​useGeneratedKeys+keyProperty(推

Python通用唯一标识符模块uuid使用案例详解

《Python通用唯一标识符模块uuid使用案例详解》Pythonuuid模块用于生成128位全局唯一标识符,支持UUID1-5版本,适用于分布式系统、数据库主键等场景,需注意隐私、碰撞概率及存储优... 目录简介核心功能1. UUID版本2. UUID属性3. 命名空间使用场景1. 生成唯一标识符2. 数

Linux系统性能检测命令详解

《Linux系统性能检测命令详解》本文介绍了Linux系统常用的监控命令(如top、vmstat、iostat、htop等)及其参数功能,涵盖进程状态、内存使用、磁盘I/O、系统负载等多维度资源监控,... 目录toppsuptimevmstatIOStatiotopslabtophtopdstatnmon

java使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class

Java中的数组与集合基本用法详解

《Java中的数组与集合基本用法详解》本文介绍了Java数组和集合框架的基础知识,数组部分涵盖了一维、二维及多维数组的声明、初始化、访问与遍历方法,以及Arrays类的常用操作,对Java数组与集合相... 目录一、Java数组基础1.1 数组结构概述1.2 一维数组1.2.1 声明与初始化1.2.2 访问

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

一文详解SpringBoot中控制器的动态注册与卸载

《一文详解SpringBoot中控制器的动态注册与卸载》在项目开发中,通过动态注册和卸载控制器功能,可以根据业务场景和项目需要实现功能的动态增加、删除,提高系统的灵活性和可扩展性,下面我们就来看看Sp... 目录项目结构1. 创建 Spring Boot 启动类2. 创建一个测试控制器3. 创建动态控制器注

C#读写文本文件的多种方式详解

《C#读写文本文件的多种方式详解》这篇文章主要为大家详细介绍了C#中各种常用的文件读写方式,包括文本文件,二进制文件、CSV文件、JSON文件等,有需要的小伙伴可以参考一下... 目录一、文本文件读写1. 使用 File 类的静态方法2. 使用 StreamReader 和 StreamWriter二、二进

Conda与Python venv虚拟环境的区别与使用方法详解

《Conda与Pythonvenv虚拟环境的区别与使用方法详解》随着Python社区的成长,虚拟环境的概念和技术也在不断发展,:本文主要介绍Conda与Pythonvenv虚拟环境的区别与使用... 目录前言一、Conda 与 python venv 的核心区别1. Conda 的特点2. Python v