博客

1. 添加注解

@EnableAsync

2. 创建异步线程池

@Configuration
public class ExecutorConfig {
    @Bean("aExecutor")
    public Executor asyncServiceExecutor() {
        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
                .setNameFormat("aExecutor-%s").build();
        int size = 200;
        ExecutorService executor = Executors.newFixedThreadPool(size, namedThreadFactory);
        return executor;
    }
}

3. 创建发布异步事件类（专用于执行异步方法的一个service类）

@Async("aExecutor")
    public void test() {
        aService.a();
    }