在一次SpringBoot中使用Scheduled定時任務時，發(fā)現(xiàn)某一個任務出現(xiàn)執(zhí)行占用大量資源，會導致其他任務也執(zhí)行失敗。
類似于以下模擬場景，test1定時任務模擬有五秒鐘執(zhí)行時間，這時會同步影響到test2任務的執(zhí)行，導致test2任務也變成五秒執(zhí)行一次。

    @Scheduled(fixedRate = 1000)
    public void test1() throws InterruptedException {
        log.info(Thread.currentThread().getName() + " | task01 ");
        Thread.sleep(5000);
    }

    @Scheduled(fixedRate = 2000)
    public void test2() {
        log.info(Thread.currentThread().getName() + " | task02 ");
    }

原因分析：

經過相關資料查閱，發(fā)現(xiàn)Scheduled定時任務默認的線程數(shù)只有一個，進行定時任務調度時會同步的去調度，一個執(zhí)行完成后再執(zhí)行另一個，這是導致該問題的直接原因。

解決方案：

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        // 設置線程數(shù)量
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }

添加一個配置，設置TaskScheduler線程數(shù)為多個，這樣再執(zhí)行時就會異步執(zhí)行了，各個定時任務間互不影響。

補充：

使用以下Java的util包中帶的TimerTask也可以進行定時任務的執(zhí)行。
以下參數(shù)中TimerTask是執(zhí)行的任務，0表示第一次延遲0秒執(zhí)行，3000表示每3000毫秒執(zhí)行一次。

						// true表示定時任務創(chuàng)建為守護線程
                        Timer timer = new Timer(true);
                        //timer.scheduleAtFixedRate();
                        timer.schedule(new TimerTask() {
                            @Override
                            public void run() {
                                logger.info(Thread.currentThread().getName() + "************"+ftpGaFilePrefix);
                            }
                        }, 0, 3000);

到此這篇關于SpringBoot中的Scheduled單線程執(zhí)行的文章就介紹到這了,更多相關SpringBoot Scheduled單線程內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: