Fork/Join框架是一个用于并行执行任务的框架，它的出现是为了适应多核处理器时代，提高cpu的利用率。核心思想是把一个大任务分割成若干个小任务，汇总每个小任务的结果作为大任务的结果。Fork/Join框架要完成两件事：
1、Fork(任务分割)：就是将一个大任务分割成足够小的子任务。
2、Join(执行任务并合并结果)：分割的子任务会分别保存到双端队列里，然后几个启动线程会到这个双端队列里拿取任务并执行，执行的结果会保存到另一个队列里，之后会单独启动一个线程在队列里获取数据，然后合并这些数据。
Fork/Join使用案例：（计算1~1000000的值，每个任务都执行相邻的三个数相加，只要两数之差大于等于2，就将这个任务再次拆分）
代码：
package cn.skq.forkjoin;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;class Demo extends RecursiveTask<Integer> {private int begin;private int end;public Demo(int begin, int end) {super();this.begin = begin;this.end = end;}private int sum;@Overrideprotected Integer compute() {if (end - begin <= 2) {for (int i = begin; i <= end; i++) {sum += i;}} else {Demo a = new Demo(begin, (begin + end) / 2);Demo b = new Demo((begin + end) / 2 + 1, end);a.fork();//拆分任务b.fork();//拆分任务Integer aa = a.join();//执行任务并合并结果Integer bb = b.join();//执行任务并合并结果sum = aa + bb;}return sum;}}public class Test {public static void main(String[] args) {ForkJoinPool pool = new ForkJoinPool();Future<Integer> future = pool.submit(new Demo(1, 1000000));try {System.out.println(future.get());} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (ExecutionException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
}