FutureTask是Java中用于异步计算的任务类，实现Future和Runnable接口，可包装Callable或Runnable，支持获取结果、取消任务和检查状态。通过new Thread或线程池执行，结合get()获取结果（可设超时），isDone()判断完成状态，cancel()尝试取消任务。推荐在生产环境使用线程池提交FutureTask以提升资源管理效率。注意调用get()时应设置超时避免阻塞，合理处理中断与异常，从而实现高效并发控制。
在Java中，FutureTask 是一个可取消的异步计算任务，它实现了 Future 和 Runnable 接口，可以用来包装 Callable 或 Runnable 对象。通过 FutureTask，你可以启动一个异步任务，并在需要时获取其结果或检查执行状态。
创建并运行 FutureTask
要使用 FutureTask，先创建一个 Callable 或 Runnable 任务，然后将其包装进 FutureTask 实例中。由于 FutureTask 实现了 Runnable 接口，它可以被线程直接执行，也可以提交给线程池。
- Callable 可以返回结果并抛出异常，适合用于有返回值的异步计算。
- Runnable 不返回结果，适用于只执行操作的场景。
示例代码：
import java.util.concurrent.*;
public class FutureTaskExample {
public static void main(String[] args) {
// 创建 Callable 任务
Callable task = () -> {
System.out.println("开始计算...");
Thread.sleep(2000);
return 42;
};
// 包装成 FutureTask
FutureTask futureTask = new FutureTask<>(task);
// 启动线程执行任务
new Thread(futureTask).start();
try {
// 获取结果（会阻塞直到任务完成）
Integer result = futureTask.get();
System.out.println("计算结果：" + result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
}
检查任务状态与取消执行
FutureTask 提供了多种方法来管理任务的生命周期，包括判断是否完成、是否被取消以及主动取消任务。
立即学习“Java免费学习笔记（深入）”；
- isDone()：判断任务是否已完成（正常结束、异常或被取消）。
- isCancelled()：判断任务是否已被取消。
- cancel(boolean mayInterruptIfRunning)：尝试取消任务。参数决定是否中断正在运行的线程。
示例：带超时和取消机制的任务控制
try {
// 设置最多等待1秒，超时则抛出 TimeoutException
Integer result = futureTask.get(1, TimeUnit.SECONDS);
System.out.println("结果：" + result);
} catch (TimeoutException e) {
System.out.println("任务超时，准备取消");
futureTask.cancel(true); // 中断执行中的任务
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
结合线程池使用 FutureTask
虽然可以直接用 new Thread 执行 FutureTask，但在生产环境中更推荐将其提交给线程池执行，便于资源管理和性能优化。
你可以将 FutureTask 提交到 ExecutorService，或者直接接收其返回的 Future 对象进行控制。
ExecutorService executor = Executors.newFixedThreadPool(2); CallablelongTask = () -> { Thread.sleep(3000); return "任务完成"; }; Future future = executor.submit(longTask); try { String result = future.get(2, TimeUnit.SECONDS); System.out.println(result); } catch (TimeoutException e) { System.out.println("超时！取消任务"); future.cancel(true); } executor.shutdown();
基本上就这些。FutureTask 给你提供了对异步任务的精细控制能力，无论是获取结果、处理异常还是取消执行，都能灵活应对。合理使用它，能有效提升程序的并发处理效率。不复杂但容易忽略的是中断响应和超时设置，建议每次调用 get() 时都考虑是否需要加超时保护。
