这篇文章主要介绍了Java中forkjoin的原理和forkjoin怎么应用的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇Java中forkjoin的原理和forkjoin怎么应用文章都会有所收获，下面我们一起来看看吧。

ForkJoinTask就是ForkJoinPool里面的每一个任务。他主要有两个子类：RecursiveAction和RecursiveTask。然后通过fork()方法去分配任务执行任务，通过join()方法汇总任务结果

这就是整个过程的运用。他有两个子类，使用这两个子类都可以实现我们的任务分配和计算。

（1）RecursiveAction 一个递归无结果的ForkJoinTask（没有返回值）

（2）RecursiveTask 一个递归有结果的ForkJoinTask（有返回值）

ForkJoinPool：中含有一个workQueues队列；

workQueues：由ForkJoinTask数组和workerThread和指向ForkJoinPool的引用；

ForkJoinTask数组负责存放程序提交给ForkJoinPool的任务，而workerThread数组负责执行这些任务，ForkJoinPool的引用是为了当ForkJoinTask数组中的任务处理完之后再次获取任务交给workerThread进行处理。

知识点扩展：Java并发Fork-Join框架原理解析

1、什么是Foirk/Join框架

Fork/Join框架是Java7提供用于并行执行任务的框架，是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架。

2、什么是并行流与顺序流2.1 什么是并行流？

并行流就是把一个内容分成多个数据块，并用不同的线程分别处理每个数据块的流。

2.2 工作窃取模式

某个线程从其他队列里窃取任务来执行，

3、使用Fork/Join框架

/***累加运算测试*/publicclassForkJoinCalculateextendsRecursiveTask<Long>{/****/privatestaticfinallongserialVersionUID=7125244951292834932L;privatelongstart;//起始值privatelongend;//结束值privatestaticfinallongTHRESHOLD=10000L;//临界值@OverrideprotectedLongcompute(){longlength=end-start;if(length<=THRESHOLD){longsum=0L;for(longi=start;i<=end;i++){sum+=i;}returnsum;}else{longmiddle=(start+end)/2;//中间值ForkJoinCalculateleft=newForkJoinCalculate(start,middle);//0-50000000left.fork();//拆分子任务，同时压入线程队列ForkJoinCalculateright=newForkJoinCalculate(middle+1,end);//50000001-100000000right.fork();//拆分子任务，同时压入线程队列returnleft.join()+right.join();//汇总任务结果}}publicForkJoinCalculate(){}publicForkJoinCalculate(longstart,longend){this.start=start;this.end=end;}}

4、Java8中的并行流和顺序流

4.1顺序流

/***Java8的顺序流*/@Testpublicvoidtest3(){Instantstart=Instant.now();//java8中新时间日期APILongStream.rangeClosed(0,10000000000L).sequential()//顺序流.reduce(0,Long::sum);Instantend=Instant.now();//5780System.out.println("耗费时间为："+Duration.between(start,end).toMillis());//java8中新时间日期API}

4.2步行流

/***Java8的并行流*/@Testpublicvoidtest4(){Instantstart=Instant.now();//java8中新时间日期APILongStream.rangeClosed(0,10000000000L).parallel()//并行流.reduce(0,Long::sum);Instantend=Instant.now();//2392System.out.println("耗费时间为："+Duration.between(start,end).toMillis());//java8中新时间日期API}

关于“Java中forkjoin的原理和forkjoin怎么应用”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“Java中forkjoin的原理和forkjoin怎么应用”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注亿速云行业资讯频道。