FutureTask 是兼具 Runnable 和 Future 的任务容器，可手动创建、提交至线程池，支持结果获取、取消和状态查询；还可封装为带超时、重试的模板类，并配合 CompletionService 实现按完成顺序处理结果。
在 Java 线程池中结合 FutureTask 实现自定义异步计算任务，核心是利用 FutureTask 作为可提交、可取消、可获取结果的“任务容器”，再通过线程池执行它。它比直接提交 Callable 更灵活，因为你可以复用、重试、手动触发或干预执行流程。
理解 FutureTask 的双重角色
FutureTask 既是 Runnable 又是 Future，这意味着它：
• 可以被线程池的 execute() 或 submit() 接收（因实现了 Runnable）
• 支持阻塞等待结果（get()）、超时获取（get(long, TimeUnit)）、主动取消（cancel(true)）和查询状态（isDone() / isCancelled()）
• 构造时传入 Callable（推荐）或 Runnable + result，内部封装了结果缓存与状态机
手动创建并提交 FutureTask 到线程池
不依赖 ExecutorService.submit() 自动包装，而是显式构造 FutureTask，便于后续控制：
ExecutorService pool = Executors.newFixedThreadPool(4);
<p>// 自定义 Callable（比如耗时计算）
Callable<String> task = () -> {
Thread.sleep(1000);
return "done at " + System.currentTimeMillis();
};</p><p>// 显式创建 FutureTask
FutureTask<String> futureTask = new FutureTask<>(task);</p><p>// 提交（注意：用 execute，不是 submit —— 避免二次包装）
pool.execute(futureTask);</p><p>// 后续可随时 get（阻塞），或 cancel，或检查状态
try {
String result = futureTask.get(); // 等待完成并取值
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}封装成可复用的异步任务模板类
为提升可维护性，可将通用逻辑抽成泛型模板，例如支持失败重试、回调通知、超时配置：
public class AsyncTask<T> extends FutureTask<T> {
private final String taskId;
private final long timeoutMs;
<pre class="brush:php;toolbar:false;">public AsyncTasks(Callable<T> callable, String taskId, long timeoutMs) {
super(callable);
this.taskId = taskId;
this.timeoutMs = timeoutMs;
}
public T getResult() throws ExecutionException, InterruptedException {
try {
return get(timeoutMs, TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
cancel(true);
throw new RuntimeException("Task " + taskId + " timed out", e);
}
}}
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
// 使用示例
AsyncTask
结合 CompletionService 统一管理多个 FutureTask
当需并发提交多个 FutureTask 并按完成顺序处理结果时，建议搭配 CompletionService：
ExecutorService pool = Executors.newFixedThreadPool(4);
CompletionService<String> service = new ExecutorCompletionService<>(pool);
<p>// 提交多个 FutureTask（也可提交普通 Callable，本质一样）
for (int i = 0; i < 3; i++) {
FutureTask<String> ft = new FutureTask<>(() -> {
Thread.sleep((long) (Math.random() * 2000));
return "result-" + i;
});
service.submit(ft); // 内部会包装成 Future 并注册监听
}</p><p>// 按完成先后顺序取结果，无需轮询 isDone()
for (int i = 0; i < 3; i++) {
try {
String result = service.take().get(); // take() 阻塞直到有完成任务
System.out.println("Completed: " + result);
} catch (Exception e) {
e.printStackTrace();
}
}不复杂但容易忽略：FutureTask 的 run() 方法只能执行一次，重复调用无效；cancel(true) 仅对正在运行的任务发送中断信号，不能保证立即停止——需在 Callable 内部配合 Thread.interrupted() 做响应式退出。
