ForkJoin的使用

2024-02-10 12:32
文章标签 使用 forkjoin

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

可以先简单了解下【JDK中的ForkJoin机制】。

1、使用ForkJoin来实现数组中元素排序,使用invoke方法和submit方法。

package com.su.mybatis.oracle.controller;import java.util.Arrays;
import java.util.Random;
//import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
//import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;import com.alibaba.fastjson.JSON;public class Test {public static void main(String[] args) {long startTime = System.currentTimeMillis();ForkJoinPool pool = new ForkJoinPool();int[] array = produceArray(100);System.out.println("排序前:" + JSON.toJSONString(array));SortTask task = new SortTask(array);//1、使用invoke方法(同步)int[] result = pool.invoke(task);System.out.println("排序后:" + JSON.toJSONString(result));
//        //2、使用submit方法(异步)
//        ForkJoinTask<int[]> result = pool.submit(task);
//        try {
//            System.out.println("排序后:" + JSON.toJSONString(result.get()));
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        } catch (ExecutionException e) {
//            e.printStackTrace();
//        }System.out.println("花费时间:" + (System.currentTimeMillis()- startTime) + "ms");}static class SortTask extends RecursiveTask<int[]> {private static final long serialVersionUID = -2039880513818337443L;private final int LIMIT = 2;private int[] array;public SortTask(int[] array) {this.array = array;}@Overrideprotected int[] compute() {if(array.length <= LIMIT){//插入排序return insertionSort(array);}else{//归并排序int mid = array.length / 2;SortTask leftTask = new SortTask(Arrays.copyOfRange(array, 0, mid));SortTask rightTask = new SortTask(Arrays.copyOfRange(array, mid, array.length));invokeAll(leftTask,rightTask);int[] leftResult = leftTask.join();int[] rightResult = rightTask.join();return merge(leftResult,rightResult);}}}//生成随机数组public static int[] produceArray(int arrayLength) {Random r = new Random();int[] array = new int[arrayLength];for(int i=0;i<arrayLength;i++){array[i] =  r.nextInt(arrayLength*arrayLength);}return array;}/** 两个数组合并成一个数组,升序排列 */public static int[] merge(int[] left, int[] right) {int[] result = new int[left.length + right.length];for (int index = 0, i = 0, j = 0; index < result.length; index++) {if (i >= left.length)result[index] = right[j++];else if (j >= right.length)result[index] = left[i++];else if (left[i] > right[j])result[index] = right[j++];elseresult[index] = left[i++];}return result;}/** 插入排序 */public static int[] insertionSort(int[] array) {if (array.length == 0)return array;int currentValue;for (int i = 0; i < array.length - 1; i++) {int preIndex = i;currentValue = array[preIndex + 1];while (preIndex >= 0 && currentValue < array[preIndex]) {array[preIndex + 1] = array[preIndex];preIndex--;}array[preIndex + 1] = currentValue;}return array;}
}

使用invoke方法,输出结果:

排序前:[4310,1357,7626,506,1766,1430,8181,4019,6694,4816,445,962,6648,5475,7002,6318,2765,6712,6553,3651,2939,4180,6427,4941,2380,846,265,6194,661,769,5090,687,7633,2780,868,8475,5706,1751,1778,280,4356,6881,4040,4391,9366,6116,1080,3035,533,6938,495,9190,8879,5353,858,4624,4081,3945,5119,7223,966,9319,4569,5328,9420,7010,6899,3034,9636,2578,4480,9699,5494,4456,7893,7989,2463,3969,9204,5656,1912,5972,8246,459,4740,2987,6931,7741,9429,974,6913,2150,5596,1338,183,787,9067,6945,765,925]
排序后:[183,265,280,445,459,495,506,533,661,687,765,769,787,846,858,868,925,962,966,974,1080,1338,1357,1430,1751,1766,1778,1912,2150,2380,2463,2578,2765,2780,2939,2987,3034,3035,3651,3945,3969,4019,4040,4081,4180,4310,4356,4391,4456,4480,4569,4624,4740,4816,4941,5090,5119,5328,5353,5475,5494,5596,5656,5706,5972,6116,6194,6318,6427,6553,6648,6694,6712,6881,6899,6913,6931,6938,6945,7002,7010,7223,7626,7633,7741,7893,7989,8181,8246,8475,8879,9067,9190,9204,9319,9366,9420,9429,9636,9699]
花费时间:142ms

使用submit方法,输出结果:

排序前:[4788,5561,3948,2328,6607,6488,7901,7459,8016,9959,2340,7412,7571,4884,919,5636,4525,2477,5363,7187,9488,9975,7424,1557,8829,7998,5775,5691,8884,3433,5567,8473,8696,5353,3215,5097,5326,2302,4191,2924,8595,5654,2783,5416,429,35,7385,1426,6138,56,4970,5513,917,9216,1835,4749,1623,6330,4030,8618,793,4869,468,6885,7880,2420,2491,7457,1825,3470,8453,6142,6892,8838,7636,832,8214,7041,961,3975,3014,7049,1307,5648,6769,6045,1405,7943,6744,4530,8744,4855,5135,939,3360,2416,5769,2720,2179,8052]
排序后:[35,56,429,468,793,832,917,919,939,961,1307,1405,1426,1557,1623,1825,1835,2179,2302,2328,2340,2416,2420,2477,2491,2720,2783,2924,3014,3215,3360,3433,3470,3948,3975,4030,4191,4525,4530,4749,4788,4855,4869,4884,4970,5097,5135,5326,5353,5363,5416,5513,5561,5567,5636,5648,5654,5691,5769,5775,6045,6138,6142,6330,6488,6607,6744,6769,6885,6892,7041,7049,7187,7385,7412,7424,7457,7459,7571,7636,7880,7901,7943,7998,8016,8052,8214,8453,8473,8595,8618,8696,8744,8829,8838,8884,9216,9488,9959,9975]
花费时间:137ms

2、查找电脑指定路径下所有以“.txt"结尾的文件,使用execute方法。

package com.su.mybatis.oracle.controller;import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;public class Test {public static void main(String[] args) {System.out.println("main 开始执行...");ForkJoinPool pool = new ForkJoinPool();SelectFilesTask task = new SelectFilesTask(new File("D:/360MoveData/"));pool.execute(task);System.out.println("main 正在执行...");try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}task.join();//插队,等待task完成System.out.println("main 结束...");}static class SelectFilesTask extends RecursiveAction {private static final long serialVersionUID = -2039880513818337443L;private File file;public SelectFilesTask(File file) {this.file = file;}@Overrideprotected void compute() {List<SelectFilesTask> tasks = new ArrayList<>();File[] files = file.listFiles();if (files!=null){for (File file : files) {if (file.isDirectory()) {//如果文件是子目录,对子目录都新建一个任务tasks.add(new SelectFilesTask(file));} else {//不是目录,判断是否是.txt结尾if (file.getAbsolutePath().endsWith(".txt")){System.out.println("文件:" + file.getAbsolutePath());}}}if (!tasks.isEmpty()) {// 在当前的 ForkJoinPool 上调度所有的子任务。for (SelectFilesTask subTask : invokeAll(tasks)) {subTask.join();}}}}}
}

输出结果:

main 开始执行...
main 正在执行...
文件:D:\360MoveData\Users\gx\Documents\sql修改.txt
文件:D:\360MoveData\Users\gx\Desktop\aaa.txt
文件:D:\360MoveData\Users\gx\Documents\修改.txt
文件:D:\360MoveData\Users\gx\Desktop\c.txt
文件:D:\360MoveData\Users\gx\Documents\草稿.txt
文件:D:\360MoveData\Users\gx\Desktop\docker命令.txt
.
.
.
文件:D:\360MoveData\Users\gx\Documents\Navicat\MySQL\logs\LogHistory.txt
文件:D:\360MoveData\Users\gx\Desktop\安装maven环境.txt
文件:D:\360MoveData\Users\gx\Desktop\电影.txt
文件:D:\360MoveData\Users\gx\Desktop\线上.txt
文件:D:\360MoveData\Users\gx\Documents\Navicat\Premium\logs\LogHistory.txt
文件:D:\360MoveData\Users\gx\Documents\NetSarang\Xshell 5 Update Log.txt
文件:D:\360MoveData\Users\gx\Desktop\jd-gui\readme.txt
文件:D:\360MoveData\Users\gx\Desktop\jd-gui\新建文本文档.txt
main 结束...

 

 

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

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



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

相关文章

shell编程之函数与数组的使用详解

《shell编程之函数与数组的使用详解》:本文主要介绍shell编程之函数与数组的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录shell函数函数的用法俩个数求和系统资源监控并报警函数函数变量的作用范围函数的参数递归函数shell数组获取数组的长度读取某下的

使用Python开发一个带EPUB转换功能的Markdown编辑器

《使用Python开发一个带EPUB转换功能的Markdown编辑器》Markdown因其简单易用和强大的格式支持,成为了写作者、开发者及内容创作者的首选格式,本文将通过Python开发一个Markd... 目录应用概览代码结构与核心组件1. 初始化与布局 (__init__)2. 工具栏 (setup_t

Python虚拟环境终极(含PyCharm的使用教程)

《Python虚拟环境终极(含PyCharm的使用教程)》:本文主要介绍Python虚拟环境终极(含PyCharm的使用教程),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录一、为什么需要虚拟环境?二、虚拟环境创建方式对比三、命令行创建虚拟环境(venv)3.1 基础命令3

Python Transformer 库安装配置及使用方法

《PythonTransformer库安装配置及使用方法》HuggingFaceTransformers是自然语言处理(NLP)领域最流行的开源库之一,支持基于Transformer架构的预训练模... 目录python 中的 Transformer 库及使用方法一、库的概述二、安装与配置三、基础使用:Pi

关于pandas的read_csv方法使用解读

《关于pandas的read_csv方法使用解读》:本文主要介绍关于pandas的read_csv方法使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录pandas的read_csv方法解读read_csv中的参数基本参数通用解析参数空值处理相关参数时间处理相关

使用Node.js制作图片上传服务的详细教程

《使用Node.js制作图片上传服务的详细教程》在现代Web应用开发中,图片上传是一项常见且重要的功能,借助Node.js强大的生态系统,我们可以轻松搭建高效的图片上传服务,本文将深入探讨如何使用No... 目录准备工作搭建 Express 服务器配置 multer 进行图片上传处理图片上传请求完整代码示例

SpringBoot条件注解核心作用与使用场景详解

《SpringBoot条件注解核心作用与使用场景详解》SpringBoot的条件注解为开发者提供了强大的动态配置能力,理解其原理和适用场景是构建灵活、可扩展应用的关键,本文将系统梳理所有常用的条件注... 目录引言一、条件注解的核心机制二、SpringBoot内置条件注解详解1、@ConditionalOn

Python中使用正则表达式精准匹配IP地址的案例

《Python中使用正则表达式精准匹配IP地址的案例》Python的正则表达式(re模块)是完成这个任务的利器,但你知道怎么写才能准确匹配各种合法的IP地址吗,今天我们就来详细探讨这个问题,感兴趣的朋... 目录为什么需要IP正则表达式?IP地址的基本结构基础正则表达式写法精确匹配0-255的数字验证IP地

使用Python实现全能手机虚拟键盘的示例代码

《使用Python实现全能手机虚拟键盘的示例代码》在数字化办公时代,你是否遇到过这样的场景:会议室投影电脑突然键盘失灵、躺在沙发上想远程控制书房电脑、或者需要给长辈远程协助操作?今天我要分享的Pyth... 目录一、项目概述:不止于键盘的远程控制方案1.1 创新价值1.2 技术栈全景二、需求实现步骤一、需求

Spring LDAP目录服务的使用示例

《SpringLDAP目录服务的使用示例》本文主要介绍了SpringLDAP目录服务的使用示例... 目录引言一、Spring LDAP基础二、LdapTemplate详解三、LDAP对象映射四、基本LDAP操作4.1 查询操作4.2 添加操作4.3 修改操作4.4 删除操作五、认证与授权六、高级特性与最佳