首页 > 文章 > java教程

JavaRecursiveTask使用与结果获取详解

时间：2026-04-20 09:00:45 126浏览收藏

RecursiveTask是Java ForkJoinPool框架中专为有返回值分治计算设计的核心抽象类，通过继承并重写compute()方法，开发者可将大任务智能拆分为子任务并行执行，再高效合并结果——如数组求和、最大值查找或归并排序等典型场景；它依托fork()异步提交、join()同步获取、阈值控制避免过度拆分，并借助工作窃取机制最大化多核CPU利用率，是提升计算密集型任务性能的优雅利器，但需注意任务粒度、无状态设计与异常处理等关键实践。

Java里如何使用RecursiveTask实现可返回结果的分治任务_RecursiveTask使用方法解析

在Java并发编程中，RecursiveTask 是 ForkJoinPool 框架中的核心类之一，用于实现可返回结果的分治算法。它继承自 ForkJoinTask，适用于将一个大任务拆分成多个子任务并行执行，最终合并结果。

什么是RecursiveTask？

RecursiveTask 是一个抽象类，用于表示有返回值的递归任务。你需要继承它并重写 compute() 方法，在该方法中实现任务的拆分与结果的合并逻辑。compute() 方法的返回值即为任务的计算结果。

与之对应的 RecursiveAction 用于无返回值的任务，而 RecursiveTask 更适合如求和、查找最大值、排序等需要返回结果的场景。

如何使用RecursiveTask实现分治任务

以“计算数组元素总和”为例，展示 RecursiveTask 的典型用法：

1. 继承 RecursiveTask 并指定返回类型

例如，我们要返回 long 类型的和：

public class SumTask extends RecursiveTask {
    private static final int THRESHOLD = 1000; // 单个任务处理的最大数组长度
    private long[] array;
    private int start, end;
public SumTask(long[] array, int start, int end) {
    this.array = array;
    this.start = start;
    this.end = end;
}

@Override
protected Long compute() {
    if (end - start <= THRESHOLD) {
        // 小任务：直接计算
        long sum = 0;
        for (int i = start; i < end; i++) {
            sum += array[i];
        }
        return sum;
    } else {
        // 大任务：拆分
        int mid = (start + end) / 2;
        SumTask leftTask = new SumTask(array, start, mid);
        SumTask rightTask = new SumTask(array, mid, end);

        leftTask.fork(); // 异步提交左任务
        long rightResult = rightTask.compute(); // 当前线程执行右任务
        long leftResult = leftTask.join(); // 等待左任务完成并获取结果

        return leftResult + rightResult;
    }
}
}

2. 提交任务到 ForkJoinPool

使用 ForkJoinPool 执行任务：

public class Main {
    public static void main(String[] args) {
        long[] data = new long[10000];
        for (int i = 0; i < data.length; i++) {
            data[i] = i + 1;
        }
    SumTask task = new SumTask(data, 0, data.length);
    ForkJoinPool pool = new ForkJoinPool();
    long result = pool.invoke(task); // 启动任务并等待结果

    System.out.println("总和：" + result);
    pool.shutdown();
}
}