这篇文章给大家介绍Java中怎么使用ForkJoinPool线程池，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
计算
安全
数据库
网络和加速
企业服务
import java.io.IOException;
import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.RecursiveAction;
import java.util.concurrent.RecursiveTask;
/**
* 分割 合并 线程池
* 类似于递归的归并排序，这个是多线程的递归排序
* jdk1.7之后加的
*/
public class ForkJoinPool {
static int[] nums = new int[1000000];
static final int MAX_NUM = 50000;
static Random random = new Random();
static {
for(int i=0; i<nums.length; i++) {
nums[i] = random.nextInt(100);
}
System.out.println("总和1:" + Arrays.stream(nums).sum());
}
/**
* ForkJoinPool里面必须是ForkJoinTask，
* 直接继承ForkJoinTask类写起来比较麻烦，
* 可以继承RecursiveAction(无返回值)和RecursiveTask(递归任务，有返回值)
*/
// static class AddTask extends RecursiveAction {
//
// int start, end;
//
// public AddTask(int start, int end) {
// this.start = start;
// this.end = end;
// }
//
// @Override
// protected void compute() {
// if(end-start <= MAX_NUM) {
// long sum = 0L;
// for(int i=start; i<end; i++) sum += nums[i];
// System.out.println("from:" + start + " to:" + end + " =" + sum);
// }else{
// int middle = start + (end - start) / 2;
//
// AddTask subTask1 = new AddTask(start, middle);
// AddTask subTask2 = new AddTask(middle, end);
// subTask1.fork();
// subTask2.fork();
// }
// }
// }
/**
* 有返回值
*/
static class AddTask extends RecursiveTask<Long> {
int start, end;
public AddTask(int start, int end) {
this.start = start;
this.end = end;
}
@Override
protected Long compute() {
if(end-start <= MAX_NUM) {
long sum = 0L;
for(int i=start; i<end; i++) sum += nums[i];
System.out.println("from:" + start + " to:" + end + " =" + sum);
return sum;
}
int middle = start + (end - start) / 2;
AddTask subTask1 = new AddTask(start, middle);
AddTask subTask2 = new AddTask(middle, end);
subTask1.fork();
subTask2.fork();
return subTask1.join() + subTask2.join();
}
}
public static void main(String[] args) {
java.util.concurrent.ForkJoinPool pool = new java.util.concurrent.ForkJoinPool();
AddTask task = new AddTask(0, nums.length);
pool.execute(task); //精灵线程
System.out.println("总和2:" + task.join());
try {
System.in.read(); //阻塞主线程
} catch (IOException e) {
e.printStackTrace();
}
}
}关于Java中怎么使用ForkJoinPool线程池就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
