ForkJoin 是JAVA并發(fā)編程提供的一個工具類创肥，可以讓我們不需要了解Runnable、Thread知識值朋，只要遵循forkjoin開發(fā)模式叹侄，就可以寫出很好的多線程并發(fā)程序。
ForkJoin是一種分而治之思想昨登，什么是分而治之呢趾代？
對于一個規(guī)模為n的問題，若該問題可以很容易的解決則直接解決丰辣，若不行撒强，就分成k個較小的子問題，這些子問題相互獨立且與原問題形式相同糯俗，遞歸的解決這些子問題尿褪，然后將結果合并得到原問題的解，這就是分而治之得湘。下面使用forkjoin實現一個歸并排序算法

public class MergeSort{
    //合并結果
    public static int[] merge(int[] left,int[] right){
      int result = new int[left.length + right.length];
      for(int index = 0,i = 0,j = 0; index < result.length; index++){
        if(i >= left.length){
          result[index] = right[j++];
        }else if(j >= right.length){
          result[index] = left[i++];
        }else if(left[i] > right[i]){
          result[index] = right[j++];
        }else{
          result[index] = left[i++];
        }
      }
    }
    public static int[] sort(int[] array){
      if(array.length == 0){
          return array;
      }
      //當前待排序數據杖玲，該元素之前的元素均已排序過
      int currentValue;
      for(int i = 0;i < array.length - 1;i++){
        int preIndex = i;
        currentValue = array[preIndex + 1];
        /*在已被排序過數據中倒序尋找合適的位置，如果當前待排序數據比待比較的數據小淘正，則將標記的元素向后移一位*/
        while(preIndex > 0 && currentValue < array[preIndex]){
          array[preIndex  + 1] = array[preIndex];
          preIndex--;
        }
          array[preIndex + 1] = currentValue;
      }
      return array;
    }
  }

  public class FKsort{
      public static class SumTask extends RecursiveTask<int[]>{
         private int[] src;
         //這里定義兩個是兩兩進行比較摆马，是最小單元
         private static final int THEHOULD = 2;
         public SumTask(int[] src){
           this.src = src;
         }
          @Override
          protected int[] compute(){
              if(src.length <= THEHOULD){
                  return MergeSort.sort(array);
              }else{
                  int mid = array.length / 2;
                  //復制左邊數組
                  SumTask left = new SumTask(Arrays.copyOfRange(src,0,mid));
                  //復制右邊數組
                  SumTask right = new SumTask(Arrays.copyOfRange(src,mid,src.length));
                  invokeAll(left,right);
                  int[]  leftResult = left.join();
                  int[]  rightResult = right.join();    
                  return MergeSort.merge(leftResult,rightResult);
            }
          }  
      }
        public static void main(String[] args){
            ForkJoinPool pool = new ForkJoinPool();
            //這里可以定制一個數組
            int[] array = {3,4,5,1,2,0,8,10,222,3456};
            SumTask task = new SumTask(array);
            //執(zhí)行命令
            pool.invoke(task);
            //獲取結果
            int[] newArray = task.join();
            System.out.println(Arrays.toString(newArray));
        }
}