Fork/Join分支合并框架

Fork/Join分支合并框架

在必要的情况下，将一个大任务拆分成多个小任务（不可再拆分），然后将小任务的计算结果进行汇总。

工作窃取模式

当一个线程上获取不到任务的时候，它将会到其他线程的尾部去截取一个任务来执行。

publicclassThreadTest{publicstaticvoidmain(String[] args){
        ForkJoinPool pool=newForkJoinPool();

        ForkJoinTask<Long> task=newForkJoinDemo(0L,100000000L);

        Long sum= pool.invoke(task);

        System.out.println(sum);}}classForkJoinDemoextendsRecursiveTask<Long>{privatestaticfinallong serivalVersionUID=-5235345621564052455L;privatelong start;privatelong end;privatestaticfinallong THURSHOLD=10000L;//临界值publicForkJoinDemo(long start,long end){this.start= start;this.end= end;}@Overrideprotected Longcompute(){long length= end- start;if(length<=THURSHOLD){long sum=0L;for(long i=start;i< end;i++){
                sum+=i;}return sum;}else{long middle=(start+ end)/2;
            ForkJoinDemo left=newForkJoinDemo(start,middle);
            left.fork();//进行拆分,压入队列
            ForkJoinDemo right=newForkJoinDemo(middle+1,end);
            right.fork();return left.join()+ right.join();}}}