JAVA7中出現的Fork/Join,類似分散式檔案系統hadoop的mapreduce思想,就是將任務分割,再分割,直到分割到滿足條件
#為了方便理解:程式邏輯可以藉用遞歸的思想,層層遞歸,直到碰到最終調件,然後層層返回;而在Fork/Join中就是,類似把每個遞歸的方法,單獨的放到一個線程中;
充分利用現代多核心處理器,對任務進行並行處理
# 如:
/** * 继承RecursiveTask 则每个子任务带返回值 * 继承RecursiveAction 则每个子任务不带返回值 */public class FockJoin1 extends RecursiveTask<Integer>{public static void main(String[] args) throws ExecutionException, InterruptedException {long l = System.currentTimeMillis(); ForkJoinPool pool = new ForkJoinPool(); //类似线程池,也实现了AbstractExecutorServiceFockJoin1 task = new FockJoin1(1,1000000000); //新建任务Future<Integer> result = pool.submit(task); //将任务提交System.out.println("result is" + result.get()); //获取结果System.err.println(System.currentTimeMillis() - l); }private final Integer index = 5000; //分割任务的基数private final Integer left;private final Integer right;public FockJoin1(Integer left, Integer right) {this.left = left;this.right = right; } @Overrideprotected Integer compute() {int sum = 0;if(right - left < index) { //如果任务 小于基数,则直接执行;类似递归的出口for (int i = left; i <= right; i++) { sum += i; } }else { //任务 大于基数,则分割,类似与二分法,也可以更多int middle = (right + left) >> 1; FockJoin1 myf1 = new FockJoin1(left, middle); //二分法左边FockJoin1 myf2= new FockJoin1(middle+1, right); //二分法右边myf1.fork(); //继续执行,类似递归myf2.fork(); //继续执行,类似递归Integer integer1 = myf1.join(); //等待Integer integer2 = myf2.join(); sum = integer1 + integer2; //结果合并 }return sum; } }
##########rrreee###### ##############rrreee######
以上是java7中出現的Fork/Join介紹及用法的詳細內容。更多資訊請關注PHP中文網其他相關文章!