FutureTask 的 run 方法通过 volatile + CAS 实现线程安全的状态控制与结果封装,防止重复执行并确保结果正确传递;执行时先检查 state == NEW,再 CAS 设置 runner 并双重校验,状态按 NEW → COMPLETING → NORMAL/EXCEPTIONAL 流转,COMPLETING 为短暂中间态以串行化 outcome 赋值;成功或异常均需 CAS 进入 COMPLETING 后写入 outcome,失败则退出;终态触发唤醒 waiters 和调用 done() 钩子,全程无锁。

FutureTask 的 run 方法不是简单执行任务,而是围绕状态控制、线程安全和结果封装构建的一套严谨机制。它的核心在于:**用 volatile + CAS 保证多线程下状态变更的原子性与可见性,同时防止重复执行、确保结果正确传递**。
run 方法的执行入口与双重校验逻辑
当线程池或 Thread 调用 futureTask.run() 时,并不会无条件执行 Callable。它首先做两层防护:
-
初始状态检查:判断
state == NEW,只有新建未启动的任务才允许进入后续流程;否则直接返回(比如已被其他线程抢先执行或取消) -
CAS 占坑 + 再次校验:尝试用 CAS 将当前线程设为
runner字段值,成功后立即再次检查state是否仍为NEW。这是关键的“double-check”——避免多个线程通过第一层判断后,在 CAS 前发生状态变更(如被 cancel),导致无效执行
CAS 驱动的状态跃迁过程
状态由 volatile int state 表示,所有变更均依赖 Unsafe 的 CAS 操作。正常执行路径中,状态按如下顺序流转:
- 从
NEW→COMPLETING(中间态):表示call()已返回,正准备写入结果或异常 - 再从
COMPLETING→NORMAL或EXCEPTIONAL(终态):使用Unsafe.putOrderedInt更新,因终态不可逆,无需强同步,仅需保证写入对其他线程可见
注意:COMPLETING 不代表任务正在运行,而代表“已运行完,正落库”。它极短暂,只为串行化结果赋值过程,避免并发写 outcome 字段。
立即学习“Java免费学习笔记(深入)”;
结果与异常的原子写入保障
无论 call() 正常返回还是抛出异常,都必须在 COMPLETING 状态下完成 outcome 设置:
- 成功时:先 CAS 尝试将
state设为COMPLETING,成功则赋值outcome = result,再putOrderedInt设为NORMAL - 失败时:同样先 CAS 到
COMPLETING,再赋值outcome = ex,最后设为EXCEPTIONAL - 若任一 CAS 失败(如被其他线程抢先更新状态),整个流程立即退出,不执行后续赋值——这是防止覆盖结果的关键防线
唤醒等待线程与钩子回调
状态到达终态(NORMAL/EXCEPTIONAL/CANCELLED等)后,会触发两个动作:
- 遍历内部 waiters 栈(单向链表结构),逐个 unpark 阻塞在
get()上的线程 - 调用
done()钩子方法,供子类扩展(如日志记录、资源清理),该方法在结果可用且唤醒完成后执行
整个过程不依赖锁,完全基于 volatile 变量语义与 CAS 原子操作,是典型的无锁并发设计范例。


















