Fork/Join

用于并行执行任务的框架， 是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架。

多线程的目的不仅仅是提高程序运行的性能,但是可以充分利用CPU资源

fork()    在当前线程运行的线程池中安排一个异步执行。简单的理解就是再创建一个子任务。

join()    当任务完成的时候返回计算结果。

invoke()    开始执行任务，如果必要，等待计算完成。

举例：

实现1 到 100 相加

public class Demo extends RecursiveTask<Integer>{

    private int begin;
    private int end;

    public Demo(int begin, int end) {
        this.begin = begin;
        this.end = end;
    }

    @Override
    protected Integer compute() {
        int sum = 0;
        //拆分任务
        if (end - begin <= 2){
            for (int i = begin;i<=end;i++){
                sum += i;
            }
        }else {
            //拆分
            Demo d1 = new Demo(begin,(begin+end)/2);
            Demo d2 = new Demo((begin+end)/2+1,end);

            d1.fork();
            d2.fork();

            Integer a = d1.join();
            Integer b = d2.join();
            sum = a+b;
        }
        return sum;
    }

    public static void main(String[] args) throws Exception {
        ForkJoinPool pool = new ForkJoinPool();

        Future<Integer> future = pool.submit(new Demo(1,100));

        System.out.println("do something...");

        System.out.println("计算的值为："+ future.get());

    }
}

Console:

do something...
计算的值为：5050