SpringBoot的@EnableAsync和@Async注解分析

@Configuration
@EnableAsync
public class ThreadPoolConfig implements AsyncConfigurer {
    private static final Logger log = LoggerFactory.getLogger(ThreadPoolConfig.class);
    @Autowired
    private ThreadPoolParamsConfig threadPoolParamsConfig;
    @Override
    @Bean("taskExecutor")
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(threadPoolParamsConfig.getCorePoolSize());
        executor.setMaxPoolSize(threadPoolParamsConfig.getMaxPoolSize());
        executor.setQueueCapacity(threadPoolParamsConfig.getQueueCapacity());
        executor.setKeepAliveSeconds(threadPoolParamsConfig.getKeepAliveSeconds());
        executor.setThreadNamePrefix("authority-manage-thread-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (ex,method,params) -> {
          log.error("异常信息：{}",ex.getMessage());
          log.error("exception method:{}",method.getName());
        };
    }
}

@Data
@Component
@ConfigurationProperties(prefix = "task.pool")
public class ThreadPoolParamsConfig {
    /**
     * 核心线程数
     */
    private int corePoolSize;
    /**
     * 最大线程数
     */
    private int maxPoolSize;
    /**
     * 线程空闲空间
     */
    private int keepAliveSeconds;
    /**
     * 任务队列容量
     */
    private int queueCapacity;
}

/**
 * 测试异步创建任务
 * @return
 */
public Result createIsueTask() {
    inspPlanRlnToolService.asynsBatchCreateIsueTasks();
    return Result.ok();
}

/**
 * 异步创建任务
 */
@Async("taskExecutor")
@Override
public void asynsBatchCreateIsueTasks() {
    log.info("这是一个异步任务");
}