解決SpringBoot中的Scheduled單線程執(zhí)行問題
問題描述
在一次SpringBoot中使用Scheduled定時任務時,發(fā)現(xiàn)某一個任務出現(xiàn)執(zhí)行占用大量資源,會導致其他任務也執(zhí)行失敗。
類似于以下模擬場景,test1定時任務模擬有五秒鐘執(zhí)行時間,這時會同步影響到test2任務的執(zhí)行,導致test2任務也變成五秒執(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)過相關資料查閱,發(fā)現(xiàn)Scheduled定時任務默認的線程數(shù)只有一個,進行定時任務調(diào)度時會同步的去調(diào)度,一個執(zhí)行完成后再執(zhí)行另一個,這是導致該問題的直接原因。
解決方案:
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
// 設置線程數(shù)量
taskScheduler.setPoolSize(50);
return taskScheduler;
}添加一個配置,設置TaskScheduler線程數(shù)為多個,這樣再執(zhí)行時就會異步執(zhí)行了,各個定時任務間互不影響。

補充:
使用以下Java的util包中帶的TimerTask也可以進行定時任務的執(zhí)行。
以下參數(shù)中TimerTask是執(zhí)行的任務,0表示第一次延遲0秒執(zhí)行,3000表示每3000毫秒執(zhí)行一次。
// true表示定時任務創(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í)行的文章就介紹到這了,更多相關SpringBoot Scheduled單線程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
SpringBoot集成swagger-ui以及swagger分組顯示操作
這篇文章主要介紹了SpringBoot集成swagger-ui以及swagger分組顯示操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09
MyBatis-Plus邏輯刪除和字段自動填充的實現(xiàn)
本文主要介紹了MyBatis-Plus邏輯刪除和字段自動填充的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-08-08
深入理解Java class文件格式_動力節(jié)點Java學院整理
對于理解JVM和深入理解Java語言, 學習并了解class文件的格式都是必須要掌握的功課2017-06-06
SpringBoot監(jiān)控Tomcat活動線程數(shù)來判斷是否完成請求處理方式
這篇文章主要介紹了SpringBoot監(jiān)控Tomcat活動線程數(shù)來判斷是否完成請求處理方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-02-02

