本篇内容介绍了“怎么用ForkJoin写一个并发执行任务的工具类BatchTaskRunner”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
实际编程中经常需要并发执行多个任务，并等待这些任务运行结束返回结果。
所以用 Java 的 ForkJoin 简单撸了一个工具类：
计算
安全
数据库
网络和加速
企业服务
package com.gitee.search.utils;
import java.util.List;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveAction;
import java.util.function.Consumer;
/**
* Batch task action
* @author Winter Lau<javayou@gmail.com>
*/
public final class BatchTaskRunner extends RecursiveAction {
protected int threshold = 5; //每个线程处理的任务数
protected List taskList;
Consumer<List> action;
/**
* @param taskList 任务列表
* @param threshold 每个线程处理的任务数
*/
private BatchTaskRunner(List taskList, int threshold, Consumer action) {
this.taskList = taskList;
this.threshold = threshold;
this.action = action;
}
/**
* 多线程批量执行任务
* @param taskList
* @param threshold
* @param action
*/
public static <T> void execute(List<T> taskList, int threshold, Consumer<List<T>> action) {
new BatchTaskRunner(taskList, threshold, action).invoke();
}
@Override
protected void compute() {
if (taskList.size() <= threshold) {
this.action.accept(taskList);
}
else {
this.splitFromMiddle(taskList);
}
}
/**
* 任务中分
* @param list
*/
private void splitFromMiddle(List list) {
int middle = (int)Math.ceil(list.size() / 2.0);
List leftList = list.subList(0, middle);
List RightList = list.subList(middle, list.size());
BatchTaskRunner left = newInstance(leftList);
BatchTaskRunner right = newInstance(RightList);
ForkJoinTask.invokeAll(left, right);
}
private BatchTaskRunner newInstance(List taskList) {
return new BatchTaskRunner(taskList, threshold, action);
}
}使用方法：
List<Integer> allTasks = Arrays.asList(1,2,3,4,5);
int taskPerThread = 1;
BatchTaskRunner.execute(allTasks, taskPerThread, tasks -> {
System.out.printf("[%s]: %s\n", Thread.currentThread().getName(), tasks);
});这里假设有5个任务(allTasks)，其中 taskPerThread 是指定每个线程处理的任务数。
而 { ... } 内就是任务的处理逻辑。
超简单。
“怎么用ForkJoin写一个并发执行任务的工具类BatchTaskRunner”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/javayou/blog/4870860
