17370845950

FutureTask是Java中兼具Runnable与Future特性的任务类，既可提交执行又支持结果获取与状态控制，适用于异步预加载等场景。

FutureTask 是 Java 并发包中一个既能当任务执行、又能拿结果的“双面手”。它实现了 Runnable 和 Future 两个接口，所以既可以被线程或线程池直接运行，又支持查询状态、取消任务、阻塞获取结果等操作。核心价值在于：让主线程不卡住地启动耗时任务，等真正需要结果时再安全取回。

FutureTask 的双重身份怎么理解

它不是单纯的“结果容器”，也不是单纯的“可执行体”，而是两者的融合：

• 作为 Runnable：能传给 Thread 构造器或提交到线程池（如 executor.execute(futureTask)），具备可调度、可执行能力；
• 作为 Future：提供 get()、cancel()、isDone() 等方法，让调用方掌控任务生命周期和结果获取时机。

这种设计省去了手动管理线程+同步变量的麻烦，也比单纯用 Future 接口更灵活——因为 Future 本身不能直接执行，必须靠 ExecutorService.submit() 返回，而 FutureTask 可独立启动。

FutureTask 的状态流转与关键行为

它内部用一个 volatile int state 管理六种状态（NEW → COMPLETING → NORMAL/EXCEPTIONAL/CANCELLED/INTERRUPTED），所有状态变更都通过 CAS 原子操作完成，确保多线程下安全。

• 刚创建是 NEW，还没 run；
• 调用 run() 后进入执行，成功则变 NORMAL，异常则变 EXCEPTIONAL；
• 调用 cancel(true) 且任务正在跑，会尝试中断线程，并最终标记为 INTERRUPTED；
• 一旦变成 NORMAL 或 EXCEPTIONAL，就不可再取消，cancel() 返回 false。

注意：get() 阻塞时不是死等，而是加入等待队列，由任务完成时唤醒；超时版 get(timeout, unit) 更适合防止无限挂起。

FutureTask 的两种构造方式与适用场景

它支持包装两类任务：

• FutureTask(Callable callable)：最常用，适用于有返回值的耗时逻辑（比如查数据库、调远程接口）；
• FutureTask(Runnable runnable, V result)：把无返回值的 Runnable “伪装”成有结果的任务，执行完固定返回你指定的 result（适合通知类任务，如“发送邮件成功”返回 "OK"）。

典型用法：主线程启动一个 FutureTask 做预加载，自己继续处理 UI 或其他请求，最后在展示页前调用 get() 拿数据——没完成就等，已完成立刻取，逻辑干净。

和线程池搭配使用的常见模式

虽然 FutureTask 可以自己 new Thread 启动，但生产环境更推荐交给线程池统一管理：

• 用 executor.submit(callable) 返回的是 Future，底层其实也是 FutureTask 实例；
• 如果想复用同一个 FutureTask 多次执行（比如重试），得调用 runAndReset()（注意：这会重置状态，但不重置结果）；
• 多个 FutureTask 提交后，可用 invokeAll() 批量等待全部完成，避免逐个 get() 的串行等待。

不复杂但容易忽略：别在循环里反复 get() 单个任务，应先提交全部，再统一收集，才能真正发挥并发优势。