Future通过Callable和FutureTask或线程池获取异步任务结果,支持阻塞获取、超时控制及任务状态判断,适用于简单异步场景。

在Java中,Future 是用于获取异步任务执行结果的一种机制。当你启动一个线程去执行耗时操作时,主线程可以继续做其他事情,等需要结果时再通过 Future 获取。下面介绍如何使用 Future 正确获取线程的执行结果。
使用 Callable 和 FutureTask
与 Runnable 不同,Callable 可以返回结果并抛出异常。将 Callable 提交到线程或线程池后,会得到一个 Future 对象,通过它获取结果。
示例代码:
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
public class FutureExample {
public static void main(String[] args) throws Exception {
// 定义一个有返回值的任务
Callabletask = () -> {
Thread.sleep(2000);
return "任务完成";
};
// 包装成 FutureTask
FutureTaskfutureTask = new FutureTask<>(task);
// 启动线程执行任务
new Thread(futureTask).start();
// 主线程可以先做别的事
System.out.println("等待结果中...");
// 获取结果(阻塞直到任务完成)
String result = futureTask.get();
System.out.println(result);
}
}
结合线程池使用 Future
实际开发中更推荐使用 ExecutorService 提交任务,它会直接返回 Future 对象。
示例代码:
import java.util.concurrent.*;
public class FutureWithPool {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newSingleThreadExecutor();
Callabletask = () -> {
int sum = 0;
for (int i = 1; i <= 5; i++) {
sum += i;
Thread.sleep(500);
}
return sum;
};
Futurefuture = executor.submit(task);
System.out.println("任务已提交,正在执行...");
// 可以设置超时,避免无限等待
try {
Integer result = future.get(3, TimeUnit.SECONDS);
System.out.println("计算结果:" + result);
} catch (TimeoutException e) {
System.out.println("任务超时,未完成");
}
executor.shutdown();
}
}
Future 的关键方法说明
Future 接口提供了几个重要方法来控制和获取任务状态:
立即学习“Java免费学习笔记(深入)”;
- get():阻塞等待任务完成,并返回结果
- get(long timeout, TimeUnit unit):最多等待指定时间,超时抛出 TimeoutException
- isDone():判断任务是否已完成(包括正常结束、异常或取消)
- isCancelled():判断任务是否被取消
- cancel(boolean mayInterruptIfRunning):尝试取消任务
注意:调用 get() 时如果任务还未完成,当前线程会被阻塞,直到结果可用或发生异常。
基本上就这些。Future 提供了基本的异步结果获取能力,适合简单场景。如果逻辑较复杂,比如需要链式处理或组合多个异步任务,建议考虑使用 CompletableFuture。不过对于大多数需要“启动线程并取结果”的情况,Future 已经足够实用。










