前言

以前负责的一个项目，从单体架构往微服务架构迁移时，引入了Consul作为服务配置中心，然后导致所有的异步定时任务（@schedule+@Async）都不执行了；跟源码发现Consul作为服务配置中心时会在client端起一个定时任务线程池（核心线程数和最大线程数均为1）其伦村Consul Server中的服务配置；

由于@Async默认使用SpringBoot自带的线程池，而这个线程池已经被Consul创建，并且核心线程数和最大线程数都为1，就导致@Async一直拿不到可用的线程，进而所有的定时任务都没有执行；

当时的解决方案：

• 自定义线程池，@Async使用时指定线程池名称，执行异步任务。

自定义线程池

在@Configuration类中通过@Bean的方式注入一个ThreadPoolTaskExecutor到Spring容器；

@Bean("myExecutor")
public ThreadPoolTaskExecutor mqInvokeAysncExecutor() {

    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    // 线程池中的线程名前缀
    executor.setThreadNamePrefix("log-message-");
    // 设置线程池关闭的时候需要等待所有任务都完成 才能销毁其他的Bean
    executor.setWaitForTasksToCompleteOnShutdown(true);
    // 设置线程池中任务的等待时间，如果超过这个时候还没有销毁就强制销毁，以确保应用最后能够被关闭，而不是阻塞住
    executor.setAwaitTerminationSeconds(120);
    executor.setCorePoolSize(4);
    executor.setMaxPoolSize(16);
    // 任务阻塞队列的大小
    executor.setQueueCapacity(20000);
    return executor;
}

使用自定义线程池

1）@Async中使用

在使用的方法上面添加@Async(“自定义线程池类beanName”)注解；

public class AsyncTest {

    // 指定使用哪个线程池，不指定则使用spring默认的线程池
    @Async("myExecutor")
    public void executeAsync() {
        System.out.println("executeAsync");
    }
}

2）CompletableFuture中使用

当使用CompletableFuture.runAsync()方法异步执行一系列任务时，可以在方法的第二个参数中指定用哪个线程池执行任务；

public class ImportOrderLogMsgProducer {

    @Resource(name = "myExecutor")
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;



    public void testAsync(LogMessage logMessage) {

        CompletableFuture.runAsync(() -> {

            try {
                // do something
            } catch (Exception e) {
                log.error("... catch:{}", e.getMessage(), e);
            }

        }, threadPoolTaskExecutor);
    }
}