Java并发编程之Fork/Join框架的示例分析

这篇文章主要介绍了Java并发编程之Fork/Join框架的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

一、Fork/Join框架的理解

• ForkJoinTask类属于java.util.concurrent 包下；

• ForkJoinTask类下有2个子类，分别为RecursiveTask和RecursiveAction类；（lz示例中使用RecursiveTask类进行重写compute()方法进行实现数值的累加计算）

• ForkJoinTask类 将一个大的任务拆分成多个子任务进行并行处理，最后将子任务结果合并成最后的计算结果，并进行输出。

二、Fork/Join框架使用示例

示例场景：对数值进行累加计算；

注：示例中使用ForkJoinTask类的子类(RecursiveTask类)进行重写compute()方法进行实现数值的累加计算

1、代码

package com.xz.thread.ForkJoin; import java.util.concurrent.ExecutionException; import java.util.concurrent.ForkJoinPool; import java.util.concurrent.ForkJoinTask; import java.util.concurrent.RecursiveTask; /**  * @description:  * @author: xz  * @create: 2021-06-06 17:15  */ public class Demo extends RecursiveTask<Integer> {     private int start;//子任务开始计算的开始值     private int end;//子任务开始计算的结束值     private static final Integer MAX_VALUE = 50;     //构造方法     public Demo(int start, int end) {         this.start = start;         this.end = end;     }     //计算     @Override     protected Integer compute() {         int sum =0;         //如果所需要计算的数值拆分为足够小，则进行累加计算         if(end-start <= MAX_VALUE){             System.out.println("startValue = " + start + ";endValue = " + end);             for(int i=start;i<=end;i++){                 sum +=i;             }         }else{//否则再进行任务拆分,拆分成2个子任务             Demo d1 = new Demo(start, (start + end) / 2);             Demo d2 = new Demo((start + end) / 2, end);             //执行2个子任务             d1.fork();             d2.fork();             //合并子任务             Integer value1= d1.join();             Integer value2= d2.join();             sum =value1+value2;         }         return sum;     }     //测试     public static void main(String[] args) throws Exception{         //ForkJoinPool主要用于实现“分而治之”的算法，特别是分治之后递归调用的函数         ForkJoinPool forkJoinPool = new ForkJoinPool();         //提交一个ForkJoinTask执行         ForkJoinTask<Integer> forkJoinTask = forkJoinPool.submit(new Demo(1,200));         System.out.println("计算结果="+forkJoinTask.get());     } }

2、运行测方法，输出如下：

感谢你能够认真阅读完这篇文章，希望小编分享的“Java并发编程之Fork/Join框架的示例分析”这篇文章对大家有帮助，同时也希望大家多多支持亿速云，关注亿速云行业资讯频道，更多相关知识等着你来学习!