Spring Controller返回CompletableFuture为何无法实现异步？

为什么两个接口表现差异？ #

1. 返回void的getDataAsyncV4() #

你在方法里启动CompletableFuture.supplyAsync()后直接返回void，Spring MVC收到返回值后会立刻给客户端返回响应（通常是200 OK空响应体），Tomcat的工作线程随即释放，后续异步任务会在后台的ForkJoinPool线程中执行，和请求线程完全解耦，所以不会出现阻塞感知。

2. 返回CompletableFuture<Data>的getDataAsyncV5() #

Spring MVC对返回CompletableFuture的接口有专属处理逻辑：它不会立刻响应客户端，而是注册回调等待Future执行完成，再把结果序列化后返回给客户端。等待期间，Tomcat的请求线程会被挂起（并非方法内部阻塞，而是Spring MVC为了返回结果而等待），所以客户端会看到请求等待1秒才收到响应，这让你误以为主线程被阻塞。

为何@EnableAsync无效？ #

@EnableAsync是配合@Async注解使用的，作用是让Spring代理被标注的方法，将方法执行转移到异步线程池。但你这里是手动创建CompletableFuture，和@EnableAsync的逻辑不相关，所以添加后不会改变当前行为。

实现“异步执行+返回结果”的正确方式 #

场景1：即时响应+后台执行任务 #

如果需要给客户端立刻返回任务启动通知，后台异步处理任务：

@GetMapping(value = "/async/data/v5")
public ResponseEntity<String> getDataAsyncV5() {
    // 用自定义线程池避免占用默认ForkJoinPool资源
    CompletableFuture.supplyAsync(() -> {
        try {
            Thread.sleep(1000);
            return Data.builder().data("Some Data").threadId(Thread.currentThread().getId()).requestCameTime(System.currentTimeMillis()).build();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }, customAsyncExecutor);
    return ResponseEntity.ok("任务已启动，可稍后查询结果");
}

场景2：异步执行+完成后返回结果 #

如果需要任务执行完成后返回结果，同时避免Tomcat线程资源浪费，可给supplyAsync传入自定义线程池：

// 先定义自定义线程池配置
@Configuration
public class AsyncConfig {
    @Bean
    public Executor customAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(20);
        executor.setThreadNamePrefix("CustomAsync-");
        executor.initialize();
        return executor;
    }
}

// Controller中注入使用
@Autowired
private Executor customAsyncExecutor;

@GetMapping(value = "/async/data/v5")
public CompletableFuture<Data> getDataAsyncV5() {
    return CompletableFuture.supplyAsync(() -> {
        try {
            Thread.sleep(1000);
            return Data.builder().data("Some Data").threadId(Thread.currentThread().getId()).requestCameTime(System.currentTimeMillis()).build();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }, customAsyncExecutor);
}

这种方式下，任务在自定义线程池执行，Spring MVC依然会等待结果返回，但Tomcat请求线程处于挂起状态（不占用CPU资源），仅客户端需等待任务完成。

内容的提问来源于stack exchange，提问作者logbasex