Future.get()会阻塞线程,应优先使用带超时的get(timeout, unit)并捕获三类异常;调用前宜用isDone()等预检;生产中推荐CompletableFuture替代原生Future实现非阻塞链式异步编程。

Future.get() 会阻塞,但不是唯一方式
调用 Future.get() 确实是最直接的取结果方法,但它会**一直阻塞当前线程直到任务完成**,甚至可能永远卡住。生产环境几乎从不裸用无参 get()。
- 必须搭配超时:用
get(long timeout, TimeUnit unit),避免线程被长期占用 - 要捕获两种异常:
ExecutionException(任务内抛出的异常)、TimeoutException(超时)、CancellationException(任务被取消) - 如果任务已失败,
get()会把原始异常包装成ExecutionException再抛出,需调用.getCause()获取根因
判断任务状态比盲目 get() 更安全
在调用 get() 前,先用状态方法做预检,能避免不必要的阻塞和异常处理负担。
-
isDone():返回true表示任务已结束(成功、失败或取消) -
isCancelled():仅当任务被主动cancel(true)且成功中断才为true - 注意:
isDone() == true不代表结果可用——若任务抛异常,get()仍会抛ExecutionException
CompletableFuture 比 Future 更实用
原生 Future 接口功能极简,没有链式回调、组合、异常处理等能力。Java 8 引入的 CompletableFuture 才是现代异步编程的实际选择。
- 支持非阻塞式结果消费:
thenAccept(result -> {...})、exceptionally(throwable -> {...}) - 可组合多个异步任务:
thenCompose()(扁平化嵌套)、thenCombine()(并行合并) - 能指定执行上下文:
thenApplyAsync(fn, executor),避免默认 ForkJoinPool 拥塞
CompletableFuture.supplyAsync(() -> fetchFromDB(), dbExecutor)
.thenApply(data -> transform(data))
.exceptionally(ex -> {
log.error("DB call failed", ex);
return fallbackData();
})
.thenAccept(result -> sendToClient(result));
不要在线程池里调用 get() 阻塞等待
在 ExecutorService 提交的任务中,再对另一个 Future 调用 get() 是典型反模式——它会浪费线程资源,还可能引发死锁(尤其使用有界队列 + 线程数少的池)。
立即学习“Java免费学习笔记(深入)”;
- 正确做法:把后续逻辑拆成回调,或改用
CompletableFuture的异步链 - 若真需同步等待,请确保该线程不属于共享线程池(比如是主线程或专用等待线程)
- 监控
Future.isDone()轮询也不推荐——消耗 CPU 且不及时,应依赖回调机制
Future 本身只是个契约接口,真正要落地异步流控、错误恢复、超时熔断,绕不开 CompletableFuture 或更上层的框架(如 Project Reactor)。原生 Future 的存在意义,更多是作为底层适配的统一抽象。










