解決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 "); }
原因分析:
經過相關資料查閱,發(fā)現(xiàn)Scheduled定時任務默認的線程數(shù)只有一個,進行定時任務調度時會同步的去調度,一個執(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單線程內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
SpringBoot集成swagger-ui以及swagger分組顯示操作
這篇文章主要介紹了SpringBoot集成swagger-ui以及swagger分組顯示操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09MyBatis-Plus邏輯刪除和字段自動填充的實現(xiàn)
本文主要介紹了MyBatis-Plus邏輯刪除和字段自動填充的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-08-08深入理解Java class文件格式_動力節(jié)點Java學院整理
對于理解JVM和深入理解Java語言, 學習并了解class文件的格式都是必須要掌握的功課2017-06-06SpringBoot監(jiān)控Tomcat活動線程數(shù)來判斷是否完成請求處理方式
這篇文章主要介紹了SpringBoot監(jiān)控Tomcat活動線程數(shù)來判斷是否完成請求處理方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-02-02