本文介绍使用 CompletableFuture 替代 DeferredResult 实现线程安全、可控超时的异步结果等待机制，解决传统 DeferredResult 在同步上下文中无法直接阻塞获取结果的问题。
本文介绍使用 `completablefuture` 替代 `deferredresult` 实现线程安全、可控超时的异步结果等待机制，解决传统 `deferredresult` 在同步上下文中无法直接阻塞获取结果的问题。
在 Spring Web 应用中，若需让一个 HTTP 请求“暂停执行”，等待外部事件（如另一接口调用、消息监听器或定时任务）设置结果后再继续处理，直接使用 DeferredResult 并在同步方法体中调用 .getResult() 是错误的用法——因为 DeferredResult.getResult() 仅返回当前已设置的值（未设置则返回 null），它不具备阻塞等待能力，也不会自动等待超时完成。
正确的替代方案是采用 java.util.concurrent.CompletableFuture：它天然支持异步编排、阻塞获取（含超时）、异常传播与线程安全组合，且与 Spring 的响应式编程模型兼容性良好。
✅ 推荐实现方式：CompletableFuture + 线程安全容器
首先，改造 RequestHolder，使用线程安全的 CopyOnWriteArrayList（比 Collections.synchronizedList 更适合读多写少场景，且避免迭代时并发修改异常）：
@Component
public class RequestHolder {
private final List<CompletableFuture<String>> requestList = new CopyOnWriteArrayList<>();
public CompletableFuture<String> addRequest() {
CompletableFuture<String> future = new CompletableFuture<>();
requestList.add(future);
return future;
}
public void completeAll(String result) {
requestList.forEach(future -> future.complete(result));
requestList.clear();
}
public void completeFirst(String result) {
if (!requestList.isEmpty()) {
requestList.remove(0).complete(result);
}
}
public int size() {
return requestList.size();
}
}接着，更新控制器逻辑，使用 CompletableFuture.get(timeout, unit) 实现带超时的阻塞等待：
@RestController
public class ExampleController {
@Autowired
private RequestHolder requestHolder;
@GetMapping("/hello")
public String hello() throws Exception {
// 创建并注册等待 future
CompletableFuture<String> waitingFuture = requestHolder.addRequest();
try {
// 阻塞等待最多 10 秒，超时抛出 TimeoutException
String myVar = waitingFuture.get(10, TimeUnit.SECONDS);
return "Success: " + myVar;
} catch (TimeoutException e) {
return "Timeout: no result received within 10 seconds";
} catch (ExecutionException e) {
return "Error: " + e.getCause().getMessage();
}
}
}对应的结果触发端（如 /setResult）只需调用 completeAll() 即可唤醒所有等待中的请求：
@RestController
public class RequestHandler {
@Autowired
private RequestHolder requestHolder;
@GetMapping("/setResult")
public String setResult() {
requestHolder.completeAll("Hello World!");
return "Triggered " + requestHolder.size() + " pending requests";
}
}⚠️ 关键注意事项
-
禁止在 WebMvc 同步控制器中阻塞主线程过久：虽然
CompletableFuture.get()可用，但长时间阻塞会耗尽 Tomcat 连接线程池。生产环境建议改用@Async+ 回调，或迁移到 WebFlux 响应式栈。 -
超时必须显式指定：
future.get()无参版本会无限等待，极易引发线程挂起；务必使用带超时的重载。 -
异常处理不可省略：
get()抛出InterruptedException、ExecutionException和TimeoutException，需统一捕获并转化为友好响应。 -
线程安全是核心前提：原始
ArrayList在多线程并发add/clear/forEach下存在严重竞态风险，CopyOnWriteArrayList或ConcurrentLinkedQueue是更稳妥的选择。
✅ 总结
DeferredResult 是为 Servlet 容器异步处理设计的底层机制，不适用于同步代码中“等待结果”的语义；而 CompletableFuture 提供了更高层次、更直观、更健壮的异步协调能力。结合合理的超时策略与线程安全集合，即可优雅实现跨请求/跨组件的结果协同，兼顾可读性、可维护性与生产可用性。
