RecursiveAction用于实现无返回值的分治任务，需继承该类并重写compute()方法，通过fork()提交子任务、join()同步完成，或使用invokeAll()批量执行；适用于CPU密集型操作如并行打印数组，需设置合理阈值避免过度拆分，并配合ForkJoinPool利用多核并行处理。
在Java中，RecursiveAction 是 ForkJoinTask 的一个子类，用于实现**无返回值的分治任务**，适用于那些可以拆解为多个子任务并并行执行、但不需要返回结果的场景。它通常与 ForkJoinPool 配合使用，以充分利用多核CPU资源。
1. RecursiveAction 基本结构
要使用 RecursiveAction，需要继承该类并重写其 compute() 方法。这个方法是任务执行的核心逻辑，在其中判断是否需要继续拆分任务（递归），还是直接处理当前小任务。
基本模板如下：
class MyTask extends RecursiveAction {
private final int threshold; // 拆分阈值
private int start, end;
MyTask(int start, int end, int threshold) {
this.start = start;
this.end = end;
this.threshold = threshold;
}
@Override
protected void compute() {
if (end - start <= threshold) {
// 直接处理小任务（例如打印、修改数组等）
for (int i = start; i zuojiankuohaophpcn end; i++) {
// 执行具体操作
}
} else {
int mid = (start + end) / 2;
MyTask left = new MyTask(start, mid, threshold);
MyTask right = new MyTask(mid, end, threshold);
invokeAll(left, right); // fork 并等待完成
}
}}
2. 实际应用：并行打印数组元素
假设我们有一个大数组，想用分治方式并行打印每个元素。由于只是输出操作，无需返回值，适合使用 RecursiveAction。
import java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveAction;public class ParallelPrintTask extends RecursiveAction { private static final int THRESHOLD = 5; private final int[] array; private final int start, end;
public ParallelPrintTask(int[] array, int start, int end) { this.array = array; this.start = start; this.end = end; } @Override protected void compute() { if (end - start <= THRESHOLD) { for (int i = start; i zuojiankuohaophpcn end; i++) { System.out.println("Thread: " + Thread.currentThread().getName() + ", Value: " + array[i]); } } else { int mid = (start + end) / 2; ParallelPrintTask left = new ParallelPrintTask(array, start, mid); ParallelPrintTask right = new ParallelPrintTask(array, mid, end); invokeAll(left, right); } } public static void main(String[] args) { int[] data = new int[20]; for (int i = 0; i zuojiankuohaophpcn data.length; i++) { data[i] = i + 1; } ForkJoinPool pool = new ForkJoinPool(); pool.invoke(new ParallelPrintTask(data, 0, data.length)); pool.shutdown(); }
}
上述代码将数组分成小段，每段小于等于5个元素时直接打印，否则继续拆分。ForkJoinPool 负责调度这些子任务并发执行。
3. 关键方法说明
- fork()：将任务提交到工作队列异步执行，不阻塞当前线程。
- join()：等待该任务完成并合并结果（虽然无返回值，但仍需 join 来同步）。
- invokeAll(tasks...)：等价于对多个任务依次调用 fork()，然后等待所有任务完成（内部自动调用 join）。
注意：不要在 compute() 中使用普通线程启动方式（如 new Thread().start()），应始终通过 fork/join 机制交由 ForkJoinPool 管理。
4. 使用建议和注意事项
- 设置合理的 阈值（threshold），避免过度拆分导致线程开销大于收益。
- 确保任务是 CPU密集型 的，I/O密集型任务不适合 ForkJoinPool。
- 共享资源访问时注意线程安全，比如多个任务同时写同一个集合需加锁或使用并发容器。
- RecursiveAction 适用于“只做不返”的场景；若需返回结果，请使用 RecursiveTask
。
基本上就这些。掌握 RecursiveAction 的核心在于理解“分而治之”+“无返回值”的设计思想，并结合 ForkJoinPool 实现高效并行处理。
