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 {
    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