1、創(chuàng)建定時任務(wù)：

@Componentpublic class AutoNotifyController { /** * 獲取RedisUtils注入的bean * * @return */ private ThreadUtil getThreadUtil() { ThreadUtil threadUtil = SpringContextUtil.getBean('threadUtil'); return threadUtil; } /** * @描述: 推送啟動充電結(jié)果的自動獲取和處理分發(fā)方法 * @輸入值: void * @返回值: void */ @Scheduled(cron = '*/5 * * * * ?') public void AutoNotifyStartChargeResult() { getThreadUtil().AutoNotifyStartChargeResult(); } /** * @描述: 推送充電狀態(tài)的自動獲取和處理分發(fā)方法 * @輸入值: void * @返回值: void */ @Scheduled(cron = '*/50 * * * * ?') public void AutoNotifyChargeStatus() { getThreadUtil().AutoNotifyChargeStatus(); } /** * @描述: 推送停止充電結(jié)果的自動獲取和處理分發(fā)方法 * @輸入值: void * @返回值: void */ @Scheduled(cron = '*/5 * * * * ?') public void AutoNotifyStopChargeResult() { getThreadUtil().AutoNotifyStopChargeResult(); } /** * @描述: 推送訂單信息的自動獲取和處理分發(fā)方法 * @輸入值: void * @返回值: void */ @Scheduled(cron = '*/5 * * * * ?') public void AutoNotifyOrderInfo() { getThreadUtil().AutoNotifyOrderInfo(); } /** * @描述: 公共信息部分的設(shè)備狀態(tài)變化推送接口的自動獲取和處理分發(fā)方法 * @輸入值: void * @返回值: void */ @Scheduled(fixedRate = 200) public void checkGunStatus() { getThreadUtil().checkGunStatus(); } /** * @描述: 對于Redis中的活躍訂單增加和刪除的輪詢執(zhí)行方法 */ @Scheduled(cron = '*/5 * * * * ?') public void ActiveOrderAddAndDelete() { getThreadUtil().ActiveOrderAddAndDelete(); } /** * @描述: 對于Redis中的結(jié)束訂單訂單增加和刪除的輪詢執(zhí)行方法 */ @Scheduled(cron = '*/5 * * * * ?') public void EndOrderAddAndDelete() { getThreadUtil().EndOrderAddAndDelete(); }}

使用 @Scheduled來創(chuàng)建定時任務(wù) 這個注解用來標注一個定時任務(wù)方法。

通過看 @Scheduled源碼可以看出它支持多種參數(shù)：

（1）cron：cron表達式，指定任務(wù)在特定時間執(zhí)行；

（2）fixedDelay：表示上一次任務(wù)執(zhí)行完成后多久再次執(zhí)行，參數(shù)類型為long，單位ms；

（3）fixedDelayString：與fixedDelay含義一樣，只是參數(shù)類型變?yōu)镾tring；

（4）fixedRate：表示按一定的頻率執(zhí)行任務(wù)，參數(shù)類型為long，單位ms；

（5）fixedRateString: 與fixedRate的含義一樣，只是將參數(shù)類型變?yōu)镾tring；

（6）initialDelay：表示延遲多久再第一次執(zhí)行任務(wù)，參數(shù)類型為long，單位ms；

（7）initialDelayString：與initialDelay的含義一樣，只是將參數(shù)類型變?yōu)镾tring；

（8）zone：時區(qū)，默認為當前時區(qū)，一般沒有用到。

2、開啟定時任務(wù)：

@SpringBootApplication@EnableSchedulingpublic class PositivebuttjointApplication extends SpringBootServletInitializer{ public static void main(String[] args) { SpringApplication.run(PositivebuttjointApplication.class, args); }

注：這里的 @EnableScheduling 注解，它的作用是發(fā)現(xiàn)注解 @Scheduled的任務(wù)并由后臺執(zhí)行。沒有它的話將無法執(zhí)行定時任務(wù)。

引用官方文檔原文：

@EnableScheduling ensures that a background task executor is created. Without it, nothing gets scheduled.

3、執(zhí)行結(jié)果（單線程）

就完成了一個簡單的定時任務(wù)模型，下面執(zhí)行springBoot觀察執(zhí)行結(jié)果：

從控制臺輸入的結(jié)果中我們可以看出所有的定時任務(wù)都是在同一個線程池用同一個線程來處理的，那么我們?nèi)绾蝸聿l(fā)的處理各定時任務(wù)呢，請繼續(xù)向下看。

4、多線程處理定時任務(wù)：

1.開啟多線程

@SpringBootApplication@EnableScheduling@EnableAsyncpublic class PositivebuttjointApplication extends SpringBootServletInitializer{ public static void main(String[] args) { SpringApplication.run(PositivebuttjointApplication.class, args); }

加入@EnableAsync開啟多線程

2.使用多線程

@Async public void AutoNotifyStartChargeResult() { }

　調(diào)用的方法上加上@Async使用多線程

3.配置連接池

@Configurationpublic class ScheduleConfiguration implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler(this.getTaskScheduler()); } private ThreadPoolTaskScheduler getTaskScheduler() { ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); taskScheduler.setPoolSize(20); taskScheduler.setThreadNamePrefix('schedule-pool-'); taskScheduler.initialize(); return taskScheduler; }}

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網(wǎng)。