我眼中的并发编程——Fork/Join模型

if(我的任务足够小){
     直接工作
}else{
     任务划分成两份，
      执行并等待结果。
}

package com.itunic.concurrent;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;

public class CountTask extends RecursiveTask<Long> {

 private static final long serialVersionUID = 1L;
 private long start;
 private long end;
 // 区分任务颗粒度
 private static final int THRESHOLD = 2;

 public CountTask(long start, long end) {
 this.start = start;
 this.end = end;
    }

 @Override
 protected Long compute() {
 long sum = 0;
 boolean canCompute = (end - start) <= THRESHOLD;
 // 判断任务的颗粒度是否足够小
 if (canCompute) {
 for (long i = start; i < end; i++) {
                sum += i;
            }
        } else {
 // 将数据切分
 long middle = (start + end) / 2;
            CountTask task1 = new CountTask(start, middle);
            CountTask task2 = new CountTask(middle, end);
 // 发起两个线程任务
            invokeAll(task1, task2);
 // 等待线程返回结果
 long result1 = task1.join();
 long result2 = task2.join();
            sum = result1 + result2;
        }
 return sum;
    }

 public static void main(String[] args) throws InterruptedException, ExecutionException {
        ForkJoinPool pool = new ForkJoinPool();
        ForkJoinTask<Long> future = pool.submit(new CountTask(1, 10));
        System.out.printf("统计结果为:%s",future.get());

    }

}