Java线程池ForkJoinPool实例解析
人气:0这篇文章主要介绍了Java线程池ForkJoinPool实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
背景:ForkJoinPool的优势在于,可以充分利用多cpu,多核cpu的优势,把一个任务拆分成多个“小任务”,把多个“小任务”放到多个处理器核心上并行执行;当多个“小任务”执行完成之后,再将这些执行结果合并起来即可。这种思想值得学习。
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(); } } }
您可能感兴趣的文章:
加载全部内容