首页 > 软件编程 > java > SpringBoot异步任务

SpringBoot中的异步任务解析

2023-10-17 10:28:55 作者：不服輸的麻雀

这篇文章主要介绍了SpringBoot中的异步任务解析,SpringBoot 异步任务是一种在SpringBoot框架中使用的异步处理机制,可以提高系统的并发能力和响应速度,需要的朋友可以参考下

默认线程池：

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

在这里插入图片描述

执行任务效果：

在这里插入图片描述

自定义线程池：

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

//@Configuration
public class TheadPoolTaskConfig {

    // 核心线程数
    private static final int corePoolSize = 20;
    // 最大线程数
    private static final int maxPoolSize = 50;
    // 允许线程空闲时间
    private static final int keepAliveTime = 10;
    // 缓冲队列大小
    private static final int queueCopcity = 200;
    // 线程池前缀
    private static final String threadNamePrefix = "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;
    }
}

在这里插入图片描述

    @RequestMapping(value = "/test1", method = RequestMethod.GET)
    @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("异步任务开始执行时间:{}", format.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("异步任务执行成功！");
    }