Java的FutureTask是并发包java.util.concurrent下的一个核心类，它同时实现了Runnable和Future接口，既可以作为任务提交到线程执行，也能通过Future的相关方法获取任务的执行结果、监控任务状态，是连接任务执行和结果获取的重要桥梁。
FutureTask的核心作用
FutureTask的核心价值在于解决了异步任务执行和结果获取的解耦问题，具体作用可以分为以下几点：
- 支持异步任务执行：因为实现了Runnable接口，所以可以直接提交给Thread或者线程池执行，不需要额外封装任务载体。
- 获取任务执行结果：通过get()方法可以阻塞等待任务执行完成，拿到Callable任务返回的结果，或者捕获任务执行过程中的异常。
- 任务状态管理：可以查询任务是否完成、是否取消，也能主动取消正在执行的任务，灵活控制任务的生命周期。
- 兼容Callable和Runnable：如果传入的是Runnable任务，还可以通过构造函数指定返回结果，适配不同的任务类型。
FutureTask的工作机制
FutureTask内部通过一个volatile修饰的状态变量state来管理任务的整个生命周期，状态流转过程如下：
| 状态值 | 状态含义 |
|---|---|
| NEW | 任务初始状态，还未开始执行 |
| COMPLETING | 任务执行完成，正在设置结果 |
| NORMAL | 任务正常完成，结果已设置 |
| EXCEPTIONAL | 任务执行过程中抛出异常 |
| CANCELLED | 任务被取消，还未开始执行 |
| INTERRUPTING | 任务正在被中断 |
| INTERRUPTED | 任务已经被中断 |
当FutureTask被提交执行时，会先判断状态是否为NEW，如果是则执行内部的Callable任务的call方法。如果执行成功，会将状态从COMPLETING转为NORMAL，并保存返回结果；如果执行抛出异常，会将状态转为EXCEPTIONAL，保存异常信息。当调用get()方法时，如果任务还未完成，当前线程会被放入等待队列阻塞，直到任务完成唤醒等待线程。
FutureTask的基础使用示例
下面通过一个简单的例子展示FutureTask的基本用法，首先定义一个Callable任务：
import java.util.concurrent.Callable;
// 定义Callable任务，返回整数结果
public class SumTask implements Callable<Integer> {
private int start;
private int end;
public SumTask(int start, int end) {
this.start = start;
this.end = end;
}
@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = start; i <= end; i++) {
sum += i;
}
// 模拟任务执行耗时
Thread.sleep(1000);
return sum;
}
}
然后使用FutureTask提交任务并获取结果：
import java.util.concurrent.FutureTask;
public class FutureTaskDemo {
public static void main(String[] args) {
// 创建Callable任务实例
SumTask sumTask = new SumTask(1, 100);
// 用FutureTask包装Callable任务
FutureTask<Integer> futureTask = new FutureTask<>(sumTask);
// 创建线程执行任务
Thread thread = new Thread(futureTask);
thread.start();
try {
// 阻塞获取任务结果，最长等待2秒
Integer result = futureTask.get();
System.out.println("1到100的求和结果是：" + result);
} catch (Exception e) {
e.printStackTrace();
}
}
}
FutureTask的进阶应用场景
1. 任务取消场景
如果异步任务执行时间过长，我们可以主动取消任务，示例如下：
import java.util.concurrent.FutureTask;
public class FutureTaskCancelDemo {
public static void main(String[] args) {
FutureTask<String> futureTask = new FutureTask<>(() -> {
// 模拟长时间执行的任务
for (int i = 0; i < 5; i++) {
System.out.println("任务执行中：" + i);
Thread.sleep(1000);
}
return "任务完成";
});
Thread thread = new Thread(futureTask);
thread.start();
// 主线程等待1.5秒后取消任务
try {
Thread.sleep(1500);
// 尝试取消任务，true表示如果任务正在执行则中断线程
boolean cancelResult = futureTask.cancel(true);
System.out.println("任务取消结果：" + cancelResult);
// 再次调用get会抛出CancellationException
futureTask.get();
} catch (Exception e) {
System.out.println("获取结果异常：" + e.getMessage());
}
}
}
2. 线程池结合使用
FutureTask通常和线程池搭配使用，提升任务执行效率：
import java.util.concurrent.*;
public class FutureTaskThreadPoolDemo {
public static void main(String[] args) throws Exception {
// 创建固定大小的线程池
ExecutorService executor = Executors.newFixedThreadPool(2);
// 创建两个FutureTask任务
FutureTask<Integer> task1 = new FutureTask<>(() -> {
Thread.sleep(1000);
return 100;
});
FutureTask<Integer> task2 = new FutureTask<>(() -> {
Thread.sleep(1500);
return 200;
});
// 提交任务到线程池
executor.submit(task1);
executor.submit(task2);
// 获取两个任务的结果
Integer result1 = task1.get();
Integer result2 = task2.get();
System.out.println("任务1结果：" + result1 + "，任务2结果：" + result2);
System.out.println("两个结果之和：" + (result1 + result2));
// 关闭线程池
executor.shutdown();
}
}
使用FutureTask的注意事项
- get()方法会阻塞当前线程，如果任务长时间不完成会导致线程阻塞，建议设置超时时间，比如使用get(long timeout, TimeUnit unit)方法。
- cancel(true)方法只是给执行任务的线程发送中断信号，如果任务内部没有响应中断的逻辑，任务可能不会立即停止。
- 同一个FutureTask实例只能被执行一次，重复提交会抛出异常或者没有效果，需要多次执行的话要创建新的FutureTask实例。
- 如果任务执行过程中抛出异常，调用get()方法会抛出ExecutionException，需要通过getCause()方法获取原始的异常信息。
FutureTask是Java并发编程中处理异步任务结果的重要工具，理解它的状态流转和内部机制，能帮助我们在实际开发中更合理地使用它，避免异步任务处理中的常见问题。
FutureTaskJava并发CallableRunnable线程池修改时间：2026-07-04 06:48:28