原理解析：fork分解，join結(jié)合。這個(gè)框架的本質(zhì)是將一個(gè)任務(wù)分解成多個(gè)子任務(wù)，每個(gè)子任務(wù)用單獨(dú)的線程去處理。這里用到了遞歸的思想。框架的結(jié)構(gòu)圖可以參考

圖片來(lái)源(http://www.ibm.com/developerworks/cn/java/j-lo-forkjoin/index.html)

使用fork/join 框架很簡(jiǎn)單，

1.實(shí)現(xiàn)子問(wèn)題的一般求解算法

2.如何分解問(wèn)題

3.繼承 RecursiveAction ，實(shí)現(xiàn)compute()方法

偽代碼代碼

  Result solve(Problem problem) {     
if (problem is small)     
    directly solve problem     
else {     
    split problem into independent parts     
    fork new subtasks to solve each part     
    join all subtasks     
    compose result from subresults     
}   

這里我通過(guò)一個(gè)改進(jìn)的二分查找來(lái)講解fork/join的使用。(后面才發(fā)現(xiàn)，選用這個(gè)案例是非常失敗的，因?yàn)槎植檎业臅r(shí)間是logn,而創(chuàng)建線程的開銷更大，這樣并不能體現(xiàn)多線程二分查找的優(yōu)勢(shì)，所以這個(gè)代碼不具有實(shí)用性，只是為了說(shuō)明如何使用框架：)

代碼如下：

BinarySearchProblem.java

Java代碼

package testjdk7;     
    
import java.util.Arrays;     
/**    
 * @author kencs@foxmail.com    
 */    
public class BinarySearchProblem {     
    private final int[] numbers;     
    private final int start;     
    private final int end;     
    public final int size;     
         
    public BinarySearchProblem(int[] numbers,int start,int end){     
        this.numbers = numbers;     
        this.start = start;     
        this.end = end;     
        this.size = end -start;     
    }     
         
    public int searchSequentially(int numberToSearch){     
       //偷懶，不自己寫二分查找了     
       return Arrays.binarySearch(numbers, start, end, numberToSearch);     
    }     
         
    public BinarySearchProblem subProblem(int subStart,int subEnd){     
        return new BinarySearchProblem(numbers,start+subStart,start+subEnd);     
    }     
}  

BiSearchWithForkJoin.java

Java代碼

package testjdk7;     
import java.util.concurrent.ForkJoinPool;     
import java.util.concurrent.RecursiveAction;     
    
/**    
 * @author kencs@foxmail.com    
 */    
public class BiSearchWithForkJoin extends RecursiveAction {     
    private final int threshold;     
    private final BinarySearchProblem problem;     
    public int result;     
    private final int numberToSearch;     
         
    public BiSearchWithForkJoin(BinarySearchProblem problem,int threshold,int numberToSearch){     
        this.problem = problem;     
        this.threshold = threshold;     
        this.numberToSearch = numberToSearch;     
    }     
    
    @Override    
    protected void compute() {     
       if(problem.size < threshold){ //小于閥值，就直接用普通的二分查找     
           result = problem.searchSequentially(numberToSearch);     
       }else{     
           //分解子任務(wù)     
           int midPoint = problem.size/2;     
           BiSearchWithForkJoin left = new BiSearchWithForkJoin(problem.subProblem(0, midPoint),threshold,numberToSearch);     
           BiSearchWithForkJoin right = new BiSearchWithForkJoin(problem.subProblem(midPoint+1, problem.size),threshold,numberToSearch);     
           invokeAll(left,right);     
           result = Math.max(left.result, right.result);     
       }     
    }     
         
    //構(gòu)造數(shù)據(jù)     
    private static final int[] data = new int[1000_0000];     
    static{     
        for(int i = 0;i<1000_0000;i++){     
            data[i] = i;     
        }     
    }     
    public static void main(String[] args){     
       BinarySearchProblem problem = new BinarySearchProblem(data,0,data.length);     
       int threshold = 100;     
       int nThreads = 10;     
       //查找100_0000所在的下標(biāo)     
       BiSearchWithForkJoin  bswfj = new BiSearchWithForkJoin(problem,threshold,100_0000);     
       ForkJoinPool fjPool = new ForkJoinPool(nThreads);     
       fjPool.invoke(bswfj);     
       System.out.printf("Result is:%d%n",bswfj.result);     
    }     
         
         
}   

RecursiveTask 還可以帶返回值，這里給出一段代碼作為參考(斐波那契函數(shù))

(來(lái)自http://www.ibm.com/developerworks/cn/java/j-lo-forkjoin/index.html)

Java代碼

class Fibonacci extends RecursiveTask {     
    final int n;     
    
    Fibonacci(int n) {     
        this.n = n;     
    }     
    
    private int compute(int small) {     
        final int[] results = { 1, 1, 2, 3, 5, 8, 13, 21, 34, 55, 89 };     
        return results[small];     
    }     
    
    public Integer compute() {     
        if (n <= 10) {     
            return compute(n);     
        }     
        Fibonacci f1 = new Fibonacci(n - 1);     
        Fibonacci f2 = new Fibonacci(n - 2);     
        System.out.println("fork new thread for " + (n - 1));     
        f1.fork();     
        System.out.println("fork new thread for " + (n - 2));     
        f2.fork();     
        return f1.join() + f2.join();     
    }     
}   

用途

只要問(wèn)題能夠分解成類似子問(wèn)題的，都可以使用這個(gè)框架。對(duì)于大批量的數(shù)據(jù)尤其合適

參考資料

Jdk7官網(wǎng) http://openjdk.java.net/projects/jdk7/

(注：這篇文章發(fā)表時(shí)，JDK7未正式公布，可能有誤差，具體以官方正式版為準(zhǔn))

【編輯推薦】

1. NetBeans 7.0公布路線圖 將針對(duì)JDK 7進(jìn)行更新
2. NetBeans 6.10 M1發(fā)布 增強(qiáng)WebLogic支持
3. Java 7將于明年7月28日正式發(fā)布面向開發(fā)者
4. Java 7，一個(gè)技術(shù)標(biāo)準(zhǔn)的商業(yè)咒語(yǔ)
5. Java 7 未按時(shí)發(fā)布 計(jì)劃再次延期