SpringBoot中的异步任务解析

2023-11-19 14:40 开发作者：不服輸的麻雀

默认线程池：

使用方式：开启异步任务，在启动类上使用注解@EnableAsync启动异步任务，在需要异步执行的任务上使用@Async标注该方法为异步任务。

SpringBoot中的异步任务解析

执行任务效果：

SpringBoot中的异步任务解析

自定义线程池：

使用方式：创建线程池配置类，对线程池核心线程数量、最大线程数量、空闲线程数量、任务队列以及拒绝策略的设置，在线程池配置类上使用@Configuration进行配置文件装配，对需要异步执行的任务上标明线程池名称即可使用指定的线程池执行任务，不标注则为默认线程池执行。

//@Configuration
public class TheadPoolTaskConfig {

    // 核心线程数
    private static final int corePoolSize = 20;
    // 最大线程数
    privawww.devze.comte static final int maxPoolSize = 50;
    // 允许线程空闲时间
    private static final int keepAliveTime = 10;
    // 缓冲队列大小
    private static final int queueCopcity = 200;
    // 线程池前缀
    private static final String twww.devze.comhreadNamePrefix = "Xyamc-Thread-Service-";


    @Bean("xyamcTaskExcutor")
    public ThreadPoolTaskExecutor startTask(){
        ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
        pool.setCorePoolSize(corePoolSize);
        pool.setMaxPoolSize(maxPoolSize);
        pool.setQueueCapacity(queueCopcity);
        pool.setKeepAliveSeconds(keepAliveTime);
        pool.setThreadNamePrefix(threadNamePrefix);

        // 线程池拒绝策略
        pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        pool.initialize();
        return pool;
    }
}

SpringBoot中的异步任务解析

    @RequestMapping(value = "/test1", method = RequestMethod.G编程客栈ET)
    @ApiOperation(value = "执行默认线程池异步任务")
    public Result<?> test1(HttpServletRequest req, HttpServletResponse response) {
        iTestService.printSecond();
        return Result.ok("同步任务执行成功！");
    }

    @Override
//    @Async("xyamcTaskExcutor")
    public void printSecond() {
        Date date = new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        log.info("异步任务开始执行时间:{}", fophprmat.format(date));
        try {
            Thread.sleep(30000);
            Thread thread = Thread.currentThread();
            log.info("当前线程名称：{}", thread.getName());
            Date date1 = new Date();
            log.info("异步任务执行结束时间:{}", format.format(date1));
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        log.info("异步任务执行成功！");
    }