futuretask 是 java 中包装异步任务的核心类,实现 runnable 和 future 接口,支持提交执行、结果获取、取消及状态查询;它可包装 callable 或 runnable,但不可重用,且线程安全。

FutureTask 是 Java 中用于包装异步计算任务的核心类,它实现了 Runnable 和 Future 接口,既能提交给线程池执行,又能主动获取、取消或查询任务状态。
创建 FutureTask 的两种常用方式
FutureTask 通常包装一个 Callable(支持返回值和异常),也可包装 Runnable(但返回值为 null)。
- 用
Callable构造:适合需要返回结果的异步任务,例如耗时的数据库查询或网络请求 - 用
Runnable + result构造:当任务逻辑是 Runnable,但你希望 get() 返回指定默认值(如成功标志)时使用
提交到线程池并获取结果
FutureTask 本身可直接 run,但更常见的是交给 ExecutorService 执行。调用 get() 会阻塞直到任务完成;若任务抛出异常,get() 会重新抛出 ExecutionException,其 getCause() 返回原始异常。
- 建议搭配
try-catch处理InterruptedException和ExecutionException - 可调用
get(long timeout, TimeUnit unit)设置超时,避免无限等待 - 任务未完成时调用
isDone()或isCancelled()可安全判断状态
主动取消与中断协作
调用 cancel(true) 会尝试中断正在运行的任务线程。但能否真正停止,取决于任务内部是否响应中断(例如定期检查 Thread.interrupted() 或使用可中断的阻塞方法如 BlockingQueue.take())。
-
cancel(false)仅取消尚未开始的任务,不中断已运行的线程 - 被取消后调用
get()会抛出CancellationException - 务必在任务逻辑中配合
if (Thread.currentThread().isInterrupted()) return;等退出机制
注意线程安全与重用限制
FutureTask 是一次性对象:一旦任务完成(无论正常结束、异常或被取消),就不能再次执行。重复调用 run() 或提交到线程池不会生效。
- 不要将同一个 FutureTask 实例多次 submit 给线程池
- 若需重复执行相同逻辑,应每次新建 FutureTask 实例
- 其内部状态(如结果、异常)由 volatile 字段保证可见性,get/cancel 等操作线程安全
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











