ForkJoin
- Fork/Join框架是JAVA7提供的一個用于并行執行任務的框架，是一個把大任務分割成若干個小任務，最終匯總每個小任務結果后得到大任務結果的框架
?
Fork/Join中兩個重要的類
- ForkJoinTask：使用該框架，需要創建一個ForkJoin任務，它提供在任務中執行fork和join操作的機制。
- 一般情況下，我們并不需要直接繼承ForkJoinTask類，只需要繼承它的子類，它的子類有兩個：
- RecursiveAction:用于沒有返回結果的任務
- RecursiveTask:用于有返回結果的任務
- ForkJoinPool：任務ForkJoinTask需要通過ForkJoinPool來提交任務
package com.example.core.juc;import java.util.concurrent.*;public class UseForkJoin extends RecursiveTask<Integer> {//執行計算并要求返回結果的需要繼承RecursiveTask<Integer>//RecursiveTask<Integer>其中Integer為計算的類型private static final int THRESHOLD = 2;//閾值，也就是拆分的原則private int start;private int end;public UseForkJoin(int start,int end){this.start = start;this.end = end;}@Overrideprotected Integer compute(){int sum = 0; //1+2+3+......+100boolean canCompute = (end - start) <= THRESHOLD;if(canCompute){for(int i = start;i<=end;i++){sum += i;}}else{//如果，任務數大于閾值的情況，就進行拆分 fork操作 然后去join//1 + 100/2 = 50int middle = (start + end)/2;UseForkJoin leftTask = new UseForkJoin(start,middle);UseForkJoin rightTask = new UseForkJoin(middle+1,end);//執行左右兩邊的任務leftTask.fork();rightTask.fork();//等待任務執行完成之后，進行獲取結果int leftResult = leftTask.join();int rightResult = rightTask.join();sum = leftResult + rightResult;}return sum;}public static void main(String[] args) throws InterruptedException, ExecutionException {ForkJoinPool pool = new ForkJoinPool();UseForkJoin ufj = new UseForkJoin(1,100);Future<Integer> result = pool.submit(ufj);System.out.println("最終的結果是:"+result.get());}
}
/*
output:
最終的結果是:5050*/?
