Future是Java中用于获取异步计算结果的核心接口,通过ExecutorService提交Callable任务获取Future对象,调用其get()方法可阻塞获取结果,支持超时和异常处理,同时提供isDone()、isCancelled()和cancel()方法管理任务状态,使用完成后需关闭线程池以避免资源泄漏。
在Java中,Future 是用于获取异步计算结果的核心接口。它通常与 ExecutorService 配合使用,用来提交任务并在未来某个时间点获取执行结果。下面介绍如何正确使用 Future 实现异步调用并获取返回值。
要使用 Future,首先需要通过线程池提交一个有返回值的任务。Java 中的 Callable 接口允许任务返回结果,与 Runnable 不同。
示
例代码:
ExecutorService executor = Executors.newSingleThreadExecutor(); Callabletask = () -> { Thread.sleep(2000); return "Hello from async"; }; Future future = executor.submit(task);
通过 Future 的 get() 方法可以获取任务的返回值。这个方法是阻塞的,会一直等待直到任务完成。
示例:
try {
String result = future.get(); // 等待结果
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
Future 还提供了非阻塞的方式来管理任务生命周期。
例如,在等待前先检查状态:
if (!future.isDone()) {
System.out.println("任务还在执行...");
}
// 超时处理
String result = future.get(3, TimeUnit.SECONDS);
基本上就这些。Future 提供了基础的异步结果获取机制,虽然功能有限,但在简单场景下非常实用。注意使用完成后调用 executor.shutdown() 关闭线程池,避免资源泄漏。不复杂但容易忽略。