forkjoinpool 通过工作窃取机制提升多核利用率，每个线程维护双端队列，本线程从队尾存取任务，空闲线程从其他队列队首窃取；任务须继承 recursivetask 或 recursiveaction 才能被调度和窃取。
Java 中的 ForkJoinPool 通过“工作窃取（Work-Stealing）”机制提升多核 CPU 利用率，其核心在于每个线程维护一个双端队列（Deque），任务由本线程“压入”队尾、从队尾“弹出”执行；而空闲线程则从其他线程队列的**队首**“窃取”任务——这样既减少竞争，又保持负载均衡。
任务必须继承 RecursiveTask 或 RecursiveAction
只有 ForkJoin 框架识别的子类才能被正确调度和窃取：
-
RecursiveTask<v></v>：有返回值的任务（如计算斐波那契数） -
RecursiveAction：无返回值的任务（如遍历并修改数组元素） - 不能直接提交
Runnable或Callable（除非用ForkJoinPool#submit(Runnable)，但此时不参与窃取逻辑）
任务需主动调用 fork() 和 join() 实现分治与合并
工作窃取本身是底层调度行为，开发者需按分治模式组织任务逻辑：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 在
compute()方法中，判断是否达到可直接计算的粒度（如数据量 ≤ 阈值） - 若未达阈值，则拆分为多个子任务，对每个子任务调用
fork()（异步提交到本线程队列尾部） - 最后调用
join()等待子任务结果（此时可能触发窃取——如果子任务正被别的线程执行）
示例片段：
protected Long compute() {
if (end - start ForkJoinPool 默认使用公共池，也可自定义配置
任务提交后由池内线程自动调度，无需手动管理线程：
- 默认使用
ForkJoinPool.commonPool()（并行度 = CPU 核心数 − 1） - 如需控制，并行度可显式指定：
new ForkJoinPool(4) - 提交任务用
invoke()（阻塞等待）、submit()（返回 Future）或execute()（异步无返回） - 注意：任务对象不应共享可变状态，避免窃取线程间产生竞态
窃取行为对开发者透明，但影响性能关键点
你不需要写“窃取代码”，但需理解它如何影响设计：
- 任务粒度太粗 → 窃取机会少，负载不均；太细 → fork/join 开销大，缓存不友好
- 尽量让
compute()执行时间相对稳定，避免某些任务远慢于其他任务（导致窃取线程长期空等） - 避免在
compute()中阻塞（如 I/O、synchronized 等），否则会卡住整个窃取线程
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
