ForkJoin框架是Java 7引入的并行计算工具，采用“分而治之+工作窃取”策略高效利用多核CPU，适用于递归型、无强依赖任务；核心组件包括ForkJoinPool、ForkJoinTask（含RecursiveTask/RecursiveAction）和ForkJoinWorkerThread；工作流程为fork→并行执行→join；使用需四步：定义任务、设合理阈值、提交执行、妥善处理异常。
ForkJoin框架是Java 7引入的并行计算工具，核心目标是高效利用多核CPU处理可拆分的大任务。它不靠“堆线程”硬扛，而是用“分而治之 + 工作窃取”双策略，让任务自动拆、自动调度、自动合并，适合递归型、无强依赖的计算场景（如数组求和、树遍历、归并排序等）。
核心组件：三个关键角色
• ForkJoinPool：专用线程池，不是普通ExecutorService。它内置工作窃取机制，线程数默认为Runtime.getRuntime().availableProcessors()（通常等于CPU核心数），也可手动指定。常用获取方式：ForkJoinPool.commonPool()（共享池）或new ForkJoinPool(4)（自定义4线程）。
• ForkJoinTask：所有任务的抽象基类，实现了Future接口，支持异步控制。实际开发中不直接用它，而是继承它的两个子类：
-
RecursiveTask
：有返回值的任务（比如求和返回 long）； - RecursiveAction：无返回值的任务（比如批量打印、更新数组）。
• ForkJoinWorkerThread：专为ForkJoin设计的工作线程，每个线程绑定一个双端队列（Deque），从自己队列头部取任务，被其他空闲线程从尾部“窃取”——这是避免竞争、提升吞吐的关键设计。
立即学习“Java免费学习笔记（深入）”；
工作原理：fork → 并行执行 → join
• fork：调用task.fork()把当前任务异步提交到本线程的队列中（不是立即执行），供自己或其他线程后续拉取。
• 并行执行：ForkJoinPool中的线程持续从自己队列取任务；若队列空了，就随机找其他线程队列，从尾部偷一个任务来执行——这就是“工作窃取”。整个过程无需手动管理线程或同步。
• join：调用task.join()会阻塞等待该任务完成，并返回结果（RecursiveTask）或确保执行完毕（RecursiveAction）。注意：join()本身也支持嵌套调用，框架会自动处理依赖关系和异常传播。
使用步骤：四步写完一个并行任务
• 定义任务类：继承RecursiveTask或RecursiveAction，重写compute()方法。重点写好“拆分阈值”逻辑——当任务足够小（如数组长度≤1000），直接计算；否则一分为二，分别fork()出去。
• 设置合理阈值：不能太小（任务太多，调度开销大），也不能太大（并行度不足）。常见经验值是100~1000，具体看任务计算密度。例如求和可设THRESHOLD = 500，图像处理可能需更高。
• 提交并触发执行：用ForkJoinPool.invoke(task)（同步阻塞，推荐用于主任务）或pool.submit(task).get()（Future风格）。避免混用fork()和invoke()在同一线程中，易导致栈溢出或死锁。
• 异常处理要留意：任务中抛出的异常不会直接向上冒泡，而是被封装进ForkJoinTask.getException()。建议在compute()里捕获业务异常，或统一用try-catch包裹join()调用。
基本上就这些。它不复杂但容易忽略阈值设计和异常传递方式，用对了，CPU利用率能明显拉满；用错了，可能比单线程还慢。
