SpringBoot中如何指定自定义TaskExecutor执行CompletableFuture任务

你遇到的NoUniqueBeanDefinitionException是因为Spring容器中存在3个TaskExecutor类型的Bean：你自定义的myNewExecutor、someOtherExecutor，加上Spring Boot自动配置的taskScheduler。当你直接通过@Autowired TaskExecutor注入时，Spring无法确定要注入哪一个。

你提到用@Qualifier无效，大概率是注解使用方式错误，或者没有正确匹配Bean的名称。

下面提供几种可行的解决方式，都能保留你当前的CompletableFuture实现逻辑：

1. 正确结合@Autowired与@Qualifier指定Bean名称 #

在注入时，通过@Qualifier明确指定要注入的Bean的名称（即配置类中@Bean方法的名称）：

@Autowired
@Qualifier("myNewExecutor") // 与配置类中Bean方法名完全一致
private TaskExecutor myNewExecutor;

或者也可以使用@Resource注解（它默认按名称匹配）：

@Resource(name = "myNewExecutor")
private TaskExecutor myNewExecutor;

2. 注入具体类型的线程池Bean #

配置类中返回的是ThreadPoolTaskExecutor实现类，你可以直接注入具体类型而非父接口TaskExecutor，这样Spring能精准匹配到对应Bean：

// 配置类修改Bean方法返回具体类型
@Bean
public ThreadPoolTaskExecutor myNewExecutor() {
    RejectedExecutionHandler re = new ThreadPoolExecutor.CallerRunsPolicy();
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    executor.setMaxPoolSize(100);
    executor.setQueueCapacity(0);
    executor.setThreadNamePrefix("myNewExecutor-");
    executor.setRejectedExecutionHandler(re);
    executor.initialize(); // 手动初始化线程池，或通过@Bean(initMethod = "initialize")指定
    return executor;
}

// 业务类中注入具体类型
@Autowired
private ThreadPoolTaskExecutor myNewExecutor;

3. 标记默认的TaskExecutor为Primary（不推荐） #

如果希望myNewExecutor成为所有TaskExecutor注入的默认Bean，可以给它加上@Primary注解：

@Bean
@Primary
public TaskExecutor myNewExecutor() {
    // 配置代码不变
}

这种方式不推荐，因为会影响其他需要注入TaskExecutor的场景，可能导致意外注入错误的线程池。

你业务方法中的myMethod标注了@Async，但你是通过CompletableFuture.supplyAsync手动提交任务到自定义线程池，这里的@Async其实不会生效（因为你直接调用私有方法，没有通过Spring代理），可以考虑去掉这个@Async注解，避免混淆。

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