Spring定时任务中使用CompletableFuture为何未异步执行？

问题根源 #

• @PostConstruct执行时机导致异步代理未生效：@PostConstruct在Spring Bean初始化完成后立即执行，此时UserLookupService的异步代理尚未完全就绪，直接调用gitHubLookupService.findUser()会绕过代理逻辑，所有操作同步执行在scheduling-1线程中。
• CompletableFuture未发挥异步作用：方法中返回CompletableFuture.completedFuture(results)，但因方法本身未被异步调度，Future会立刻处于完成状态，无法实现真正的并发。

解决方案 #

1. 调整初始化逻辑执行时机：移除loadCurrentDayUsers上的@PostConstruct注解，改用ApplicationReadyEvent监听上下文初始化完成事件，确保所有代理Bean创建完成后再执行初始化。
2. 明确指定@Async线程池：在@Async注解中指定自定义线程池Bean名称，避免使用默认单线程池。
3. 优化CompletableFuture使用：@Async方法可直接返回结果，Spring会自动包装为异步Future；无需手动创建completedFuture。

修改后的代码示例 #

1. 调整MyService初始化逻辑 #

@Service  
public class MyService {  
    
    private static final Logger logger = LoggerFactory.getLogger(MyService.class);
    
    @Autowired
    private UserLookupService gitHubLookupService;
    
    @Scheduled(cron = "${cron.expression.reloadUserData}")
    public void loadCurrentDayUsers() throws Exception {
        this.loadUsers();
    }

    // 上下文就绪后触发初始化
    @EventListener(ApplicationReadyEvent.class)
    public void initAfterContextReady() throws Exception {
        this.loadUsers();
    }
    
    public void loadUsers() throws Exception {
        
        long start = System.currentTimeMillis();

        CompletableFuture<User> page1 = gitHubLookupService.findUser("PivotalSoftware");
        CompletableFuture<User> page2 = gitHubLookupService.findUser("CloudFoundry");
        CompletableFuture<User> page3 = gitHubLookupService.findUser("Spring-Projects");

        CompletableFuture.allOf(page1,page2,page3).join();

        logger.info("Elapsed time: " + (System.currentTimeMillis() - start));
        logger.info("--> " + page1.get());
        logger.info("--> " + page2.get());
        logger.info("--> " + page3.get());
    }
}

2. 修改UserLookupService的@Async配置 #

@Service  
public class UserLookupService {  

    private static final Logger logger = LoggerFactory.getLogger(UserLookupService.class);

    // 指定使用自定义线程池
    @Async("taskExecutor")
    public CompletableFuture<User> findUser(String user) throws InterruptedException {
        logger.info("Looking up " + user + ", thread: " + Thread.currentThread().getName());
        
        User results = new User();
        results.setName(user);
        results.setBlog("Blog - " + user);
        
        Thread.sleep(1000L);
        return CompletableFuture.completedFuture(results);
    }
}

3. 预期执行效果 #

修改后日志会显示使用自定义前缀线程，三个任务并发执行，耗时约1秒：

[GithubLookup-1] Looking up PivotalSoftware, thread: GithubLookup-1  
[GithubLookup-2] Looking up CloudFoundry, thread: GithubLookup-2  
[GithubLookup-3] Looking up Spring-Projects, thread: GithubLookup-3
Elapsed time: 1005

额外说明 #

• Spring@Async依赖AOP代理实现，仅通过代理对象调用方法时才会触发异步逻辑，Bean内部直接调用会绕过代理。
• 自定义线程池需确保ThreadPoolTaskExecutor正确初始化，也可通过@EnableAsync(executor="taskExecutor")指定全局默认线程池。

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