SpringBoot中的Scheduled單線程執(zhí)行問題怎么解決

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

問題描述

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

原因分析：

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

解決方案：

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

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

補充：

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

						// true表示定時任務(wù)創(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í)行問題怎么解決”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！