class MyTask extends RecursiveTask<Integer> {
    //拆分差值不能超過10，計(jì)算10以內(nèi)運(yùn)算
    private static final Integer VALUE = 10;
    private int begin ;//拆分開始值
    private int end;//拆分結(jié)束值
    private int result ; //返回結(jié)果
    //創(chuàng)建有參數(shù)構(gòu)造
    public MyTask(int begin,int end) {
        this.begin = begin;
        this.end = end;
    }
    //拆分和合并過程
    @Override
    protected Integer compute() {
        //判斷相加兩個(gè)數(shù)值是否大于10
        if((end-begin)<=VALUE) {
            //相加操作
            for (int i = begin; i <=end; i++) {
                result = result+i;
            }
        } else {//進(jìn)一步拆分
            //獲取中間值
            int middle = begin+(end- begin)/2;
            //拆分左邊
            MyTask task01 = new MyTask(begin,middle);
            //拆分右邊
            MyTask task02 = new MyTask(middle+1,end);
            //調(diào)用方法拆分
            task01.fork();
            task02.fork();
            //合并結(jié)果
            result = task01.join()+task02.join();
        }
        return result;
    }
}
public class ForkJoinDemo {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //創(chuàng)建MyTask對(duì)象
        MyTask myTask = new MyTask(0,100);
        //創(chuàng)建分支合并池對(duì)象
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        ForkJoinTask<Integer> forkJoinTask = forkJoinPool.submit(myTask);
        //獲取最終合并之后結(jié)果
        Integer result = forkJoinTask.get();
        System.out.println(result);
        //關(guān)閉池對(duì)象
        forkJoinPool.shutdown();
    }
}

package com.yxj.java8;
import java.util.concurrent.RecursiveTask;
public class ForkJoinCalculate extends RecursiveTask<Long>{
	/**
	 * 
	 */
	private static final long serialVersionUID = 13475679780L;
	private long start;
	private long end;
	private static final long THRESHOLD = 10000L; //臨界值
	public ForkJoinCalculate(long start, long end) {
		this.start = start;
		this.end = end;
	}
	@Override
	protected Long compute() {
		long length = end - start;
		if(length <= THRESHOLD){
			long sum = 0;
			for (long i = start; i <= end; i++) {
				sum += i;
			}
			return sum;
		}else{
			long middle = (start + end) / 2;
			ForkJoinCalculate left = new ForkJoinCalculate(start, middle);
			left.fork(); //拆分，并將該子任務(wù)壓入線程隊(duì)列
			ForkJoinCalculate right = new ForkJoinCalculate(middle+1, end);
			right.fork();
			return left.join() + right.join();
		}
	}
}

package com.yxj.java8;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.stream.LongStream;
import org.junit.Test;
public class TestForkJoin {
	@Test
	public void test1(){
		long start = System.currentTimeMillis();
		ForkJoinPool pool = new ForkJoinPool();
		ForkJoinTask<Long> task = new ForkJoinCalculate(0L, 10000000000L);
		long sum = pool.invoke(task);
		System.out.println(sum);
		long end = System.currentTimeMillis();
		System.out.println("耗費(fèi)的時(shí)間為: " + (end - start)); //112-1953-1988-2654-2647-20663-113808
	}
	@Test
	public void test2(){
		long start = System.currentTimeMillis();
		long sum = 0L;
		for (long i = 0L; i <= 10000000000L; i++) {
			sum += i;
		}
		System.out.println(sum);
		long end = System.currentTimeMillis();
		System.out.println("耗費(fèi)的時(shí)間為: " + (end - start)); //34-3174-3132-4227-4223-31583
	}
	@Test
	public void test3(){
		long start = System.currentTimeMillis();
		Long sum = LongStream.rangeClosed(0L, 10000000000L)
							 .parallel()
							 .sum();
		System.out.println(sum);
		long end = System.currentTimeMillis();
		System.out.println("耗費(fèi)的時(shí)間為: " + (end - start)); //2061-2053-2086-18926
	}
}