快捷導(dǎo)航

SpringBoot中的異步任務(wù)解析

更新時間：2023年10月17日 10:28:54 作者：不服輸?shù)穆槿?

這篇文章主要介紹了SpringBoot中的異步任務(wù)解析,SpringBoot 異步任務(wù)是一種在SpringBoot框架中使用的異步處理機制,可以提高系統(tǒng)的并發(fā)能力和響應(yīng)速度,需要的朋友可以參考下

默認(rèn)線程池：

使用方式：開啟異步任務(wù)，在啟動類上使用注解@EnableAsync啟動異步任務(wù)，在需要異步執(zhí)行的任務(wù)上使用@Async標(biāo)注該方法為異步任務(wù)。

在這里插入圖片描述

執(zhí)行任務(wù)效果：

在這里插入圖片描述

自定義線程池：

使用方式：創(chuàng)建線程池配置類，對線程池核心線程數(shù)量、最大線程數(shù)量、空閑線程數(shù)量、任務(wù)隊列以及拒絕策略的設(shè)置，在線程池配置類上使用@Configuration進(jìn)行配置文件裝配，對需要異步執(zhí)行的任務(wù)上標(biāo)明線程池名稱即可使用指定的線程池執(zhí)行任務(wù)，不標(biāo)注則為默認(rèn)線程池執(zhí)行。

//@Configuration
public class TheadPoolTaskConfig {

    // 核心線程數(shù)
    private static final int corePoolSize = 20;
    // 最大線程數(shù)
    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 = "執(zhí)行默認(rèn)線程池異步任務(wù)")
    public Result<?> test1(HttpServletRequest req, HttpServletResponse response) {
        iTestService.printSecond();
        return Result.ok("同步任務(wù)執(zhí)行成功！");
    }

    @Override
//    @Async("xyamcTaskExcutor")
    public void printSecond() {
        Date date = new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        log.info("異步任務(wù)開始執(zhí)行時間:{}", format.format(date));
        try {
            Thread.sleep(30000);
            Thread thread = Thread.currentThread();
            log.info("當(dāng)前線程名稱：{}", thread.getName());
            Date date1 = new Date();
            log.info("異步任務(wù)執(zhí)行結(jié)束時間:{}", format.format(date1));
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        log.info("異步任務(wù)執(zhí)行成功！");
    }