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;
<pre class='brush:java;toolbar:false;'>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 < 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 并等待完成
}
}}
立即学习“Java免费学习笔记（深入）”；
2. 实际应用：并行打印数组元素
假设我们有一个大数组，想用分治方式并行打印每个元素。由于只是输出操作，无需返回值，适合使用 RecursiveAction。
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;
<p>public class ParallelPrintTask extends RecursiveAction {
private static final int THRESHOLD = 5;
private final int[] array;
private final int start, end;</p><pre class='brush:java;toolbar:false;'>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 < 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 < data.length; i++) {
data[i] = i + 1;
}
ForkJoinPool pool = new ForkJoinPool();
pool.invoke(new ParallelPrintTask(data, 0, data.length));
pool.shutdown();
}}
立即学习“Java免费学习笔记（深入）”；
上述代码将数组分成小段，每段小于等于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<T>。
基本上就这些。掌握 RecursiveAction 的核心在于理解“分而治之”+“无返回值”的设计思想，并结合 ForkJoinPool 实现高效并行处理。
