首頁 >Java >java教程 >SpringBoot中的Scheduled單線程執行問題怎麼解決

SpringBoot中的Scheduled單線程執行問題怎麼解決

WBOY
WBOY轉載
2023-05-12 13:04:121768瀏覽

問題描述

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

    @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 ");
    }

SpringBoot中的Scheduled單線程執行問題怎麼解決

原因分析:

經過相關資料查閱,發現Scheduled定時任務預設的執行緒數只有一個,進行定時任務調度時會同步的去調度,一個執行完成後再執行另一個,這是導致該問題的直接原因。

解決方案:

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        // 设置线程数量
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }

新增一個配置,設定TaskScheduler執行緒數為多個,這樣再執行時就會非同步執行了,各個定時任務間互不影響。

SpringBoot中的Scheduled單線程執行問題怎麼解決

補充:

使用下列Java的util套件中帶的TimerTask也可以進行定時任務的執行。
以下參數中TimerTask是執行的任務,0表示第一次延遲0秒執行,3000表示每3000毫秒執行一次。

						// true表示定时任务创建为守护线程
                        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單線程執行問題怎麼解決的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:yisu.com。如有侵權,請聯絡admin@php.cn刪除