摘要:多線程并發定時任務剛剛看了下實現定時任務的文章,感覺還不錯。存在問題但是后來發現個問題,通過同時測試幾個任務發現,所有的任務都是在同一個線程池中的同一個線程來完成的。
spring-boot | 多線程并發定時任務
剛剛看了下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,也很方便。
原文地址
有問題,請留言!
個人博客地址 https://ailijie.top/archives/...
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/75981.html
摘要:表示起始時間開始觸發,然后每隔固定時間觸發一次如在域使用則意味著分鐘觸發一次,而,等分別觸發一次表示列出枚舉值值。 showImg(https://segmentfault.com/img/remote/1460000015852353); 文章鏈接:https://liuyueyi.github.io/hexblog/2018/08/01/180801-Spring之定時任務基本使用...
摘要:注意當使用注解時,為了避免并發時,存儲數據造成混亂,強烈建議把注解也加上。示例假設定時任務的時間間隔為秒,但執行時間是秒。當設置以后程序會等任務執行完畢后再去執行,否則會在秒時再啟動新的線程執行。 版權聲明:本文由吳仙杰創作整理,轉載請注明出處:https://segmentfault.com/a/1190000009128328 1. 禁止同一個 JobDetail 中的多個實例并發...
摘要:也是自帶的一個基于線程池設計的定時任務類。其每個調度任務都會分配到線程池中的一個線程執行,所以其任務是并發執行的,互不影響。 原創不易,如需轉載,請注明出處https://www.cnblogs.com/baixianlong/p/10659045.html,否則將追究法律責任!!! 一、在JAVA開發領域,目前可以通過以下幾種方式進行定時任務 1、單機部署模式 Timer:jdk中...
摘要:若以多線程的方式操作這些,則可能出現操作的沖突。另外,因為是單線程的,在某一時刻內只能執行特定的一個任務,并且會阻塞其它任務執行。瀏覽器事件觸發線程事件觸發線程,當一個事件被觸發時該線程會把事件添加到任務隊列的隊尾,等待引擎的處理。 首先,說下為什么 JavaScript 是單線程? 總所周知,JavaScript是以單線程的方式運行的。說到線程就自然聯想到進程。那它們有什么聯系呢? ...
摘要:標簽單線程首發地址碼農網細說單線程的一些事最近被同學問道單線程的一些事,我竟回答不上。若以多線程的方式操作這些,則可能出現操作的沖突。另外,因為是單線程的,在某一時刻內只能執行特定的一個任務,并且會阻塞其它任務執行。 標簽: JavaScript 單線程 首發地址:碼農網《細說JavaScript單線程的一些事》 最近被同學問道 JavaScript 單線程的一些事,我竟回答不上。好...
閱讀 1868·2023-04-25 19:51
閱讀 1168·2021-11-15 11:43
閱讀 4529·2021-11-02 14:40
閱讀 1999·2021-10-11 10:59
閱讀 1339·2021-09-22 15:05
閱讀 1027·2021-09-09 09:32
閱讀 648·2019-08-30 15:56
閱讀 549·2019-08-30 15:52