快捷導(dǎo)航

Java并發(fā)編程之Fork/Join框架的理解

更新時(shí)間：2021年06月07日 16:45:48 作者：小志的博客

今天帶大家學(xué)習(xí)Java并發(fā)編程的相關(guān)知識(shí),文中對(duì)Fork/Join框架作了非常詳細(xì)的介紹,對(duì)正在學(xué)習(xí)有關(guān)知識(shí)的小伙伴們很有幫助,需要的朋友可以參考下

一、Fork/Join框架的理解

在這里插入圖片描述

ForkJoinTask類屬于java.util.concurrent 包下；
ForkJoinTask類下有2個(gè)子類，分別為RecursiveTask和RecursiveAction類；（lz示例中使用RecursiveTask類進(jìn)行重寫compute()方法進(jìn)行實(shí)現(xiàn)數(shù)值的累加計(jì)算）
ForkJoinTask類將一個(gè)大的任務(wù)拆分成多個(gè)子任務(wù)進(jìn)行并行處理，最后將子任務(wù)結(jié)果合并成最后的計(jì)算結(jié)果，并進(jìn)行輸出。

在這里插入圖片描述

二、Fork/Join框架使用示例

示例場(chǎng)景：對(duì)數(shù)值進(jìn)行累加計(jì)算；

注：示例中使用ForkJoinTask類的子類(RecursiveTask類)進(jìn)行重寫compute()方法進(jìn)行實(shí)現(xiàn)數(shù)值的累加計(jì)算

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;//子任務(wù)開始計(jì)算的開始值
    private int end;//子任務(wù)開始計(jì)算的結(jié)束值

    private static final Integer MAX_VALUE = 50;

    //構(gòu)造方法
    public Demo(int start, int end) {
        this.start = start;
        this.end = end;
    }

    //計(jì)算
    @Override
    protected Integer compute() {
        int sum =0;
        //如果所需要計(jì)算的數(shù)值拆分為足夠小，則進(jìn)行累加計(jì)算
        if(end-start <= MAX_VALUE){
            System.out.println("startValue = " + start + ";endValue = " + end);
            for(int i=start;i<=end;i++){
                sum +=i;
            }
        }else{//否則再進(jìn)行任務(wù)拆分,拆分成2個(gè)子任務(wù)
            Demo d1 = new Demo(start, (start + end) / 2);
            Demo d2 = new Demo((start + end) / 2, end);
            //執(zhí)行2個(gè)子任務(wù)
            d1.fork();
            d2.fork();
            //合并子任務(wù)
            Integer value1= d1.join();
            Integer value2= d2.join();
            sum =value1+value2;
        }

        return sum;
    }

    //測(cè)試
    public static void main(String[] args) throws Exception{
        //ForkJoinPool主要用于實(shí)現(xiàn)“分而治之”的算法，特別是分治之后遞歸調(diào)用的函數(shù)
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        //提交一個(gè)ForkJoinTask執(zhí)行
        ForkJoinTask<Integer> forkJoinTask = forkJoinPool.submit(new Demo(1,200));
        System.out.println("計(jì)算結(jié)果="+forkJoinTask.get());
    }
}

2、運(yùn)行測(cè)方法，輸出如下：

在這里插入圖片描述