ForkJoinPool适用于分治任务，基于工作窃取算法提升并行性能。通过RecursiveTask实现任务拆分与合并，如并行求和示例所示：大任务拆为子任务，一个fork异步执行，另一个compute直接计算，最后join汇总结果。关键要点包括合理设置阈值、避免阻塞操作、优先使用公共池及及时关闭资源。适用于归并排序、树遍历等计算密集型场景，不适用共享状态频繁更新或强依赖任务。掌握分治逻辑与粒度控制可显著提升吞吐量。
在Java中，ForkJoinPool 是专为分治（Divide and Conquer）任务设计的线程池，适合处理可以递归拆分成更小子任务的计算密集型操作。它基于工作窃取（work-stealing）算法，能高效利用多核CPU资源，提升并行处理性能。
理解ForkJoinPool核心机制
ForkJoinPool 的核心思想是“分而治之”：将一个大任务拆成多个小任务（fork），然后等待它们执行完成并合并结果（join）。它内部使用ForkJoinWorkerThread来执行任务，并允许空闲线程从其他线程的任务队列中“窃取”任务，避免线程闲置。
关键组件包括：
- ForkJoinPool：执行ForkJoinTask的线程池
- ForkJoinTask：代表可拆分的异步任务，常用其子类RecursiveTask（有返回值）或RecursiveAction（无返回值）
使用RecursiveTask实现分治并行
以计算数组元素和为例，展示如何通过RecursiveTask实现并行求和：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveTask;
<p>public class SumTask extends RecursiveTask<Long> {
private final long[] array;
private final int start;
private final int end;
private static final int THRESHOLD = 1000; // 拆分阈值</p><pre class='brush:java;toolbar:false;'>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 left = new SumTask(array, start, mid);
SumTask right = new SumTask(array, mid, end);
left.fork(); // 异步提交左任务
long rightResult = right.compute(); // 当前线程执行右任务
long leftResult = left.join(); // 等待左任务结果
return leftResult + rightResult;
}
}
public static void main(String[] args) {
long[] data = new long[100_000];
for (int i = 0; i < data.length; i++) {
data[i] = i + 1;
}
ForkJoinPool pool = new ForkJoinPool();
SumTask task = new SumTask(data, 0, data.length);
long result = pool.invoke(task);
System.out.println("Sum: " + result);
pool.shutdown();
}}
这段代码中，当任务规模小于阈值时直接计算，否则拆成两个子任务。其中一个调用fork异步执行，另一个由当前线程compute处理，最后join获取结果合并。
优化与使用技巧
要发挥ForkJoinPool的最佳性能，需注意以下几点：
- 合理设置拆分阈值：太小会导致任务过多、调度开销大；太大则无法充分利用并行性。通常根据数据量和CPU核心数调整
- 避免阻塞操作：ForkJoinPool不适合执行I/O阻塞或长时间等待的任务，这会拖慢整个线程池
- 优先使用默认公共池：可通过ForkJoinPool.commonPool()获取公共实例，避免创建过多线程池。例如CompletableFuture默认就使用它
- 正确管理资源：手动创建ForkJoinPool后记得调用shutdown()
适用场景与注意事项
ForkJoinPool最适合递归结构的任务，如归并排序、快速排序、树遍历、矩阵运算等。不适用于频繁更新共享状态的场景，因为可能引发竞争。
如果任务之间存在强依赖或通信频繁，应考虑其他并发模型。同时注意StackOverflowError风险，深层递归可能导致栈溢出。
基本上就这些。掌握ForkJoinPool的关键在于理解分治逻辑和任务粒度控制，合理使用能显著提升计算密集型应用的吞吐能力。
