ForkJoinPool 专用于可递归拆分的 CPU 密集型任务，如归并排序、树遍历、并行 reduce；不适用于 I/O 多、不可分或耗时差异大的场景。
什么时候该用 ForkJoinPool 而不是普通线程池
ForkJoinPool 不是通用线程池替代品，它专为「可递归拆分的 CPU 密集型任务」设计。如果你的任务是 I/O 等待多、无法自然切分（比如单次 HTTP 请求）、或每次子任务耗时差异极大，用 ForkJoinPool 反而降低性能，甚至引发栈溢出或工作窃取失效。
典型适用场景包括：归并排序、树形结构遍历（如 JSON 解析深度优先计算）、大规模数组并行 reduce、分治型数值计算（如矩阵乘法分块）。
- 任务必须能明确 split 成两个或多个子任务，且子任务可独立执行
- 各子任务计算量尽量均衡；严重不均时，
work-stealing效果打折扣 - 避免在
compute()中做阻塞操作（如Thread.sleep()、数据库查询），否则会卡住整个池的工作线程
ForkJoinTask 的两种写法：继承 RecursiveAction 还是 RecursiveTask
区别只在是否需要返回值：RecursiveAction 无返回值（void），适合“执行即完成”类任务（如遍历并修改数组）；RecursiveTask<t></t> 必须重写 compute() 并返回 T，适合需要聚合结果的场景（如求和、找最大值）。
不要手动 new 线程或调用 fork()/join() 后再阻塞等待——这是反模式。正确流程是：构造任务 → 提交到 ForkJoinPool → 调用 invoke() 或 submit().get()。
立即学习“Java免费学习笔记（深入）”；
class SumTask extends RecursiveTask<Long> {
final long[] arr;
final int lo, hi;
SumTask(long[] arr, int lo, int hi) { this.arr = arr; this.lo = lo; this.hi = hi; }
protected Long compute() {
if (hi - lo <= 1000) { // 阈值决定是否继续分割
long sum = 0;
for (int i = lo; i < hi; i++) sum += arr[i];
return sum;
}
int mid = (lo + hi) / 2;
SumTask left = new SumTask(arr, lo, mid);
SumTask right = new SumTask(arr, mid, hi);
left.fork(); // 异步提交左任务
return right.compute() + left.join(); // 当前线程算右，再等左
}
}如何设置合适的并行度和阈值
ForkJoinPool 默认并行度等于 Runtime.getRuntime().availableProcessors()，通常无需修改。强行设成远大于 CPU 核心数（如 64）会导致上下文切换开销剧增，反而变慢。
阈值（threshold）指子任务不再拆分的最小数据规模，它比并行度更影响性能。设太小（如 10）会产生海量细粒度任务，调度开销压倒计算收益；设太大（如 100_000）则无法充分利用多核。经验法则是：让单个叶子任务执行时间落在 100μs ~ 1ms 区间，可通过 JMH 测量粗略估算。
- 阈值不是固定值，应随输入规模动态调整（例如按
arr.length / pool.getParallelism()初步估算） - 使用
ForkJoinPool.commonPool()时，无法控制并行度，且所有模块共享同一池，可能被其他框架（如 CompletableFuture）干扰 - 生产环境建议显式创建独立池：
new ForkJoinPool(4)，便于监控与隔离
常见错误：StackOverflowError 和 ManagedBlocker 的误用
递归过深是 ForkJoinTask 最隐蔽的问题。不是 JVM 栈不够，而是 ForkJoinPool 内部使用轻量级 continuation 栈，但过度嵌套（如阈值设为 1）仍会触发 StackOverflowError。根本解法是确保阈值合理，并在 compute() 入口加 guard 条件（如 if (hi ）。
ManagedBlocker 是为在 ForkJoinPool 中安全执行阻塞操作设计的，但绝大多数场景不该碰它。试图用它包装数据库调用或文件读写，会破坏 work-stealing 机制，导致线程饥饿。真有阻塞需求，请换用 Executors.newCachedThreadPool() 或 CompletableFuture.supplyAsync(..., executor) 显式指定 I/O 专用线程池。
最易被忽略的一点：ForkJoinTask 实例**不可复用**。提交后状态已变，再次 invoke() 会抛 IllegalStateException。每次计算都必须 new 新实例。
