Fork/Join

Fork/Join框架介绍

Fork/Join框架是Java 7提供了的一个用于并行执行任务的框架， 大概是怎样子的呢，就是一个把大任务分割成若干个小任务，最终把每个小任务结果汇总起来得到大任务结果的框架。有点像是归并排序。下面的图就能很好地体现出来

image

工作窃取模式(work-stealing)

在讲Fork/Join框架使用前，得先介绍一下它所使用的线程模式——工作窃取模式，何为工作窃取模式，其实就是指一个闲的发慌的线程没什么事干从其它线程的任务队列（一个双端队列）后面窃取一个任务来干。那么为什么需要这个鸟玩意呢？

其实说起来也很容易理解，比如说我是资本家，招了四个员工（代表四个线程），然后把一些任务写在清单（任务队列）上，每个员工按照清单上写的从头到尾执行一个个任务，每执行一个任务就从清单上划掉（出队），有些员工比较牛逼，很快就做完了，而有些员工比较懵逼，清单上还有很多任务没完成，于是为了竟可能压榨员工（充分利用CPU），资本家让没什么事干的员工去把还有很多事没干的员工的任务拿过来干，具体是怎么拿呢，从清单的末尾拿。大概就是这个情况，下面弄张图加强理解一下

image

package com.wangji.test;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ForkJoinPool;

import java.util.concurrent.Future;

import java.util.concurrent.RecursiveTask;

public class ForkJoinTest extends RecursiveTask {

   private static final int THRESHOLD= 2;//阈值

   private int start;

   private int end;

   public ForkJoinTest(int start,int end) {

               this.start= start;

               this.end= end;

    }
    
   @Override

   protected Integer compute() {

               int sum = 0;

               //如果任务足够小就计算任务

               boolean canCompute = (end-start) <=THRESHOLD;

               if(canCompute) {

                          for(int i =start; i <=end; i++) {

                                       sum += i;

                           }

                }else{

                          //如果任务大于阀值，就分裂成两个子任务计算

                          int middle = (start+end) / 2;

                           ForkJoinTest leftTask =new ForkJoinTest(start, middle);

                           ForkJoinTest rightTask =new ForkJoinTest(middle + 1,end);

                          //执行子任务

                           leftTask.fork();

                           rightTask.fork();

                          //等待子任务执行完，并得到其结果

                          int leftResult=(int) leftTask.join();

                          int rightResult=(int) rightTask.join();

                          //合并子任务

                           sum = leftResult  + rightResult;

                }

               return sum;

    }

   public static void main(String[] args) {

                ForkJoinPool forkJoinPool =new ForkJoinPool();

               //生成一个计算任务，负责计算1+2+3+4 
                ForkJoinTest task =new ForkJoinTest(1, 4);

               //执行一个任务

                Future result = forkJoinPool.submit(task);

               try{

                           System.out.println(result.get());

                }catch(InterruptedException e) {

                }catch(ExecutionException e) {

                }

    }

}