futuretask 状态机通过 volatile int state 字段、cas 原子操作和严格单向状态流转实现精准控制:new→completing→normal/exceptional,或取消路径 new→cancelled/interrupting→interrupted,确保线程安全与幂等性。

FutureTask 的状态机不是靠接口或继承实现的,而是靠一个 volatile int state 字段 + 原子操作 + 显式状态流转规则来达成精准控制。
state 字段是整个状态机的中枢
它用一个整型变量承载全部生命周期信息,所有状态变更都基于 CAS(Compare-And-Swap)原子操作完成,避免竞态。每个状态值有唯一含义:
- NEW(0):刚创建,任务尚未启动
- COMPLETING(1):结果正在写入,短暂中间态,防止 get() 读到半初始化数据
- NORMAL(2) 或 EXCEPTIONAL(3):任务已终态,outcome 已安全写入
- CANCELLED(4)、INTERRUPTING(5)、INTERRUPTED(6):取消相关路径,区分是否已尝试中断线程
状态流转严格遵循预设路径
源码注释明确限定合法跃迁,不允许任意跳转。比如:
- 正常完成只能走 NEW → COMPLETING → NORMAL
- 异常终止走 NEW → COMPLETING → EXCEPTIONAL
- 取消未启动任务直接到 CANCELLED;若已运行,则先到 INTERRUPTING,再设为 INTERRUPTED
这种单向不可逆设计,保证一旦进入 COMPLETING 及之后的状态,后续调用 get() 就不会阻塞——因为 outcome 已就绪或异常已捕获。
关键方法都依赖 state 做守门人
所有核心行为都以 state 当前值为前提,不满足条件则直接返回或拒绝:
- run():仅在 state == NEW 时才执行 callable.call(),否则立即 return —— 实现幂等性,避免重复执行
- get():若 state
- cancel(boolean):只对 state == NEW 的任务生效(mayInterruptIfRunning = false);若为 true,则尝试 interrupt runner 线程,但仅当 state 仍为 NEW 才能推进到 INTERRUPTING
辅助字段协同保障状态一致性
state 不是孤军奋战,它和几个 volatile 成员共同构成完整控制链:
- runner:记录正在执行任务的 Thread,cancel(true) 时用于 interrupt 目标线程
- outcome:只在 COMPLETING 后写入,且写入后 state 才升到 NORMAL/EXCEPTIONAL,防止读取到脏值
- waiters:链表结构的等待节点,在 state 达到终态后 unpark 所有挂起线程
这些字段全部用 volatile 修饰,确保多线程下可见性,配合 state 的 CAS 更新,形成一套轻量、高效、无锁(除 wait/unpark 外)的状态协调机制。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











