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

Posted on by

問題描述

在一次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 ");
    }

原因分析：

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

解決方案：

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

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

補充：

使用以下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單線程執行的文章就介紹到這瞭,更多相關SpringBoot Scheduled單線程內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：