本文共 1691 字，大约阅读时间需要 5 分钟。

多线程并行计算

/** * Created by yuanyong on 17/2/8. */import java.util.concurrent.ForkJoinPool;import java.util.concurrent.Future;import java.util.concurrent.RecursiveTask;public class CountTask extends RecursiveTask
   
     {    private static final long serialVersionUID = -3611254198265061729L;    public static final int threshold = 2;    private int start;    private int end;    public CountTask(int start, int end) {        this.start = start;        this.end = end;    }    @Override    protected Integer compute() {        int sum = 0;        //如果任务足够小就计算任务        boolean canCompute = (end - start) <= threshold;        if (canCompute) {            for (int i = start; i <= end; i++) {                sum += i;            }        } else {            // 如果任务大于阈值，就分裂成两个子任务计算            int middle = (start + end) / 2;            CountTask leftTask = new CountTask(start, middle);            CountTask rightTask = new CountTask(middle + 1, end);            // 执行子任务            leftTask.fork();            rightTask.fork();            System.out.println(Thread.currentThread().getName());            //等待任务执行结束合并其结果            int leftResult = leftTask.join();            int rightResult = rightTask.join();            //合并子任务            sum = leftResult + rightResult;        }        return sum;    }    public static void main(String[] args) {        ForkJoinPool forkjoinPool = new ForkJoinPool();        //生成一个计算任务，计算1+2+3+4        CountTask task = new CountTask(1, 100);        //执行一个任务        Future
    
      result = forkjoinPool.submit(task);        try {            System.out.println(result.get());        } catch (Exception e) {            System.out.println(e);        }    }}
    
   

转载地址：https://blog.csdn.net/u011153869/article/details/54965198 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！