Spring @Async注解方法返回空结果 线程切换正常仍失效如何解决？

根因分析 #

返回空的问题主要由以下几个常见错误导致：

• 调用方未正确处理CompletableFuture类型返回值：如果调用该异步方法的代码（通常是Controller层）直接返回CompletableFuture对象本身、或者没有调用get()/join()方法阻塞获取结果就直接使用返回值，就会得到空或者非预期的结果。虽然Spring MVC本身支持直接返回CompletableFuture自动等待完成，但如果返回值处理逻辑适配有问题就会触发空返回。
• 异步方法返回值写法不符合@Async规范：你当前手动调用CompletableFuture.completedFuture()包装返回值的写法是冗余且容易出问题的，加了@Async注解的方法不需要你手动创建已完成的Future，Spring会自动帮你把方法返回的结果包装为异步完成的Future。
• （可选排查）如果你的方法内部抛出了ResponseStatusException，异常会被封装到CompletableFuture中，若没有配置全局异步异常处理器，也可能导致返回空响应。

修复步骤 #

1. 修改异步方法的写法 #

不需要手动包装CompletableFuture，直接返回业务结果即可，Spring会自动完成包装，同时显式指定自定义线程池Bean名，避免走默认线程池：

@Async("threadPoolTaskExecutor") 
public List<Post> searchByTag(String[] tags, String sortBy, String direction ) throws ExecutionException, InterruptedException, IOException {
    logger.info("I am here---------------------------------------------------------- ");
    if(tags == null || tags.length == 0){
        throw new ResponseStatusException(HttpStatus.BAD_REQUEST , "Tags parameter is required");
    }
    if(sortBy == null){
        sortBy = "id";
    } else if(!sortBy.equals("id") && !sortBy.equals("reads") && !sortBy.equals("likes") && !sortBy.equals("popularity")){
        throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "sortBy parameter is invalid");
    }
    if(direction == null){
        direction = "asc";
    } else if(!direction.equals("asc") && !direction.equals("desc")){
        throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "direction parameter is invalid");
    }
    long start = System.currentTimeMillis();
    Set<Post> postSet = new HashSet<Post>();
    String baseUrl = "https://api.hatchways.io/assessment/blog/posts?tag=";
    HttpClient client = HttpClient.newHttpClient();

    for(int i = 0; i < tags.length; i++){
        String url = baseUrl + tags[i];
        HttpRequest request = HttpRequest.newBuilder()
                .GET()
                .header("Accept", "application/json")
                .uri(URI.create(url))
                .build();
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
        ObjectMapper mapper = new ObjectMapper();
        String responseBody = response.body().substring(9, response.body().length()-1);
        logger.info("Using Thread: " + Thread.currentThread().getName());

        List<Post> posts = mapper.readValue(responseBody, new TypeReference<List<Post>>() {});
        postSet.addAll(posts);
    }

    ArrayList<Post> postList = new ArrayList<>(postSet);
    sortThePosts(sortBy, direction, postList);
    long end = System.currentTimeMillis();
    logger.info("Total time: " + Long.toString(end-start));
    return postList;
}

2. 调整调用端逻辑 #

如果调用方是Controller层，有两种正确写法：

• 直接返回CompletableFuture<List<Post>>，Spring MVC会自动等待异步执行完成再返回响应：

@GetMapping("/search")
public CompletableFuture<List<Post>> search(@RequestParam String[] tags, @RequestParam(required = false) String sortBy, @RequestParam(required = false) String direction) {
    return searchByTag(tags, sortBy, direction);
}

• 手动调用get()获取结果（注意处理超时和异常）：

@GetMapping("/search")
public List<Post> search(@RequestParam String[] tags, @RequestParam(required = false) String sortBy, @RequestParam(required = false) String direction) throws Exception {
    CompletableFuture<List<Post>> future = searchByTag(tags, sortBy, direction);
    // 最多等待30秒，避免线程无限阻塞
    return future.get(30, TimeUnit.SECONDS);
}

3. 可选优化 #

你当前的异步方法里循环调用HTTP接口还是同步串行执行的，并没有利用到异步的优势，可以调整为并行提交多个HTTP请求，进一步缩短接口耗时。

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