您好,登錄后才能下訂單哦!
剛剛看了下Spring Boot實現定時任務的文章,感覺還不錯。Spring Boot 使用Spring自帶的Schedule來實現定時任務變得非常簡單和方便。在這里個大家分享下。
開啟緩存注解
@SpringBootApplication @EnableScheduling //開啟定時任務 public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
編寫定時任務
@Component public class ScheduledTasks { private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class); // cron接受cron表達式,根據cron表達式確定定時規則 @Scheduled(cron="0/5 * * * * ? ") //每5秒執行一次 public void testCron() { DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); logger.info(sdf.format(new Date())+"*********每5秒執行一次"); } }
任務完成
啟動項目,查看控制臺打印信息,發現定時任務已經生效。spring boot 和Scheduled整合完畢。
存在問題
但是后來發現個問題,通過同時測試幾個任務發現,所有的任務都是在同一個線程池中的同一個線程來完成的。在實際開發過程中,我們當然不希望所有的任務都運行在一個線程中。
@Scheduled(cron="0/1 * * * * ? ") //每1秒執行一次 public void testCron1() { DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); logger.info(sdf.format(new Date())+"*********每1秒執行一次"); } @Scheduled(cron="0/2 * * * * ? ") //每2秒執行一次 public void testCron2() { DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); logger.info(sdf.format(new Date())+"*********每2秒執行一次"); } @Scheduled(cron="0/3 * * * * ? ") //每3秒執行一次 public void testCron3() { DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); logger.info(sdf.format(new Date())+"*********每3秒執行一次"); } @Scheduled(cron="0/4 * * * * ? ") //每4秒執行一次 public void testCron4() { DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); logger.info(sdf.format(new Date())+"*********每4秒執行一次"); }
解決方案
那么,怎么設計成多線程實現并發呢?在網上看到過這樣的解決方案。通過ScheduleConfig配置文件實現SchedulingConfigurer接口,并重寫setSchedulerfang方法,我們嘗試著配置了一下。
@Configuration public class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5)); } }
整合成功
這樣就完成了多線程并發的配置?我們啟動項目通過控制臺輸出信息驗證一下結果,最后發現所有的任務都在同一個線程池但不同線程中完成,說明這個方案完全可行,這樣,我們就完成了spring boot 多線程并發定時任務。
注
@Scheduled所支持的參數:
1.cron:cron表達式,指定任務在特定時間執行; 2.fixedDelay:表示上一次任務執行完成后多久再次執行,參數類型為long,單位ms; 3.fixedDelayString:與fixedDelay含義一樣,只是參數類型變為String; 4.fixedRate:表示按一定的頻率執行任務,參數類型為long,單位ms; 5.fixedRateString: 與fixedRate的含義一樣,只是將參數類型變為String; 6.initialDelay:表示延遲多久再第一次執行任務,參數類型為long,單位ms; 7.initialDelayString:與initialDelay的含義一樣,只是將參數類型變為String; 8.zone:時區,默認為當前時區,一般沒有用到。
Cron表達式范例:
每隔5秒執行一次:*/5 * * * * ? 每隔1分鐘執行一次:0 */1 * * * ? 每天23點執行一次:0 0 23 * * ? 每天凌晨1點執行一次:0 0 1 * * ? 每月1號凌晨1點執行一次:0 0 1 1 * ? 每月最后一天23點執行一次:0 0 23 L * ? 每周星期天凌晨1點實行一次:0 0 1 ? * L 在26分、29分、33分執行一次:0 26,29,33 * * * ? 每天的0點、13點、18點、21點都執行一次:0 0 0,13,18,21 * * ?
其實不會Cron表達式也不用擔心,網上有好多在線Cron生成器,我們完全可以通過在線生成器生成符合要求的cron,也很方便。
總結
以上所述是小編給大家介紹的spring-boot 多線程并發定時任務的解決方案 ,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對億速云網站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。