1. 程式人生 > >spring-boot | 多執行緒併發定時任務

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整合完畢。


1240

存在問題

但是後來發現個問題,通過同時測試幾個任務發現,所有的任務都是在同一個執行緒池中的同一個執行緒來完成的。在實際開發過程中,我們當然不希望所有的任務都執行在一個執行緒中。

@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秒執行一次");
    }
1240

解決方案

那麼,怎麼設計成多執行緒實現併發呢?在網上看到過這樣的解決方案。通過ScheduleConfig配置檔案實現SchedulingConfigurer介面,並重寫setSchedulerfang方法,我們嘗試著配置了一下。


@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
    }
}

整合成功

這樣就完成了多執行緒併發的配置?我們啟動專案通過控制檯輸出資訊驗證一下結果,最後發現所有的任務都在同一個執行緒池但不同執行緒中完成,說明這個方案完全可行,這樣,我們就完成了spring boot 多執行緒併發定時任務。


1240

@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,也很方便。

(完)