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

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

WBOY
發布: 2023-05-12 13:04:12
轉載
1760 人瀏覽過

問題描述

在一次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
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板