纯净、安全、绿色的下载网站

首页|软件分类|下载排行|最新软件|IT学院

当前位置:首页IT学院IT技术

Fork/Join框架的理解 Java并发编程之Fork/Join框架的理解

小志的博客   2021-06-07 我要评论
想了解Java并发编程之Fork/Join框架的理解的相关内容吗,小志的博客在本文为您仔细讲解Fork/Join框架的理解的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Fork/Join框架的理解,java并发编程,下面大家一起来学习吧。

一、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、运行测方法,输出如下:

在这里插入图片描述

3、结论:

由第2步骤的输出结果可知,先把1到200的所有数值进行任务拆分(上图拆分成了4部分),然后再将所有子任务结的果合并成最后的计算结果


相关文章

猜您喜欢

网友评论

Copyright 2020 www.9aisf.com 【就爱软件站】 版权所有 软件发布

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 点此查看联系方式