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

本篇內容主要講解“SpringBoot中的Scheduled單線程執行問題怎么解決”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“SpringBoot中的Scheduled單線程執行問題怎么解決”吧!

問題描述

在一次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單線程執行問題怎么解決”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！