import java.util.concurrent.*;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;}//拆分和合并過程@Overrideprotected Integer compute() {//判斷相加兩個數(shù)值是否大于10if((end-begin)<=VALUE) {//相加操作for (int i = begin; i <=end; i++) {result = result+i;}} else {//進(jìn)一步拆分//獲取中間值int middle = (begin+end)/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對象MyTask myTask = new MyTask(0,100);//創(chuàng)建分支合并池對象ForkJoinPool forkJoinPool = new ForkJoinPool();ForkJoinTask<Integer> forkJoinTask = forkJoinPool.submit(myTask);//獲取最終合并之后結(jié)果Integer result = forkJoinTask.get();System.out.println(result);//關(guān)閉池對象forkJoinPool.shutdown();} }

總結(jié)

以上是生活随笔為你收集整理的ForkJoinPool---ForkJoinTask的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。