用于实现Fork/Join框架。
适用于将一个大任务拆分成多个小任务并行处理的情况。
使用场景：适用于需要利用多核处理器性能的应用程序，如图像处理、大数据分析等。
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;
public class ForkJoinPoolExample {
public static void main(String[] args) {
// 创建一个ForkJoinPool线程池，包含4个工作线程
ForkJoinPool pool = new ForkJoinPool(4);
// 提交一个任务给线程池执行
pool.submit(new RecursiveAction() {
@Override
protected void compute() {
if (size() > 0) {
int half = size() / 2;
invokeAll(new Task(0, half), new Task(half, size()));
} else {
compute();
}
}
});
// 关闭线程池
pool.shutdown();
}
}
class Task extends RecursiveAction {
private int start;
private int end;
private int[] array;
public Task(int start, int end) {
this.start = start;
this.end = end;
this.array = new int[end - start];
}
@Override
protected void compute() {
for (int i = start; i < end; i++) {
array[i] = i;
}
System.out.println("Task " + start + " - " + end + " completed");
}
}
在这个例子中，我们创建了一个ForkJoinPool线程池，并提交了一个任务给线程池执行。任务是一个递归的RecursiveAction，它会将数组分成两部分，并分别调用invokeAll方法来并行执行两个子任务。每个子任务会计算数组的一部分，并在完成后输出一条消息。最后，我们关闭了线程池。ForkJoinPool适用于处理大量计算任务，它可以将任务拆分成较小的子任务，然后使用工作窃取算法来重新分配子任务，以充分利用多核处理器的计算能力。