摘要：多線程并發(fā)定時任務(wù)剛剛看了下實現(xiàn)定時任務(wù)的文章，感覺還不錯。存在問題但是后來發(fā)現(xiàn)個問題，通過同時測試幾個任務(wù)發(fā)現(xiàn)，所有的任務(wù)都是在同一個線程池中的同一個線程來完成的。

剛剛看了下Spring Boot實現(xiàn)定時任務(wù)的文章，感覺還不錯。Spring Boot 使用Spring自帶的Schedule來實現(xiàn)定時任務(wù)變得非常簡單和方便。在這里個大家分享下。

@SpringBootApplication
@EnableScheduling //開啟定時任務(wù)
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表達式，根據(jù)cron表達式確定定時規(guī)則
    @Scheduled(cron="0/5 * * * * ? ")   //每5秒執(zhí)行一次 
    public void testCron() {
       DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
        logger.info(sdf.format(new Date())+"*********每5秒執(zhí)行一次");
    }
}

啟動項目，查看控制臺打印信息,發(fā)現(xiàn)定時任務(wù)已經(jīng)生效。spring boot 和Scheduled整合完畢。

但是后來發(fā)現(xiàn)個問題，通過同時測試幾個任務(wù)發(fā)現(xiàn)，所有的任務(wù)都是在同一個線程池中的同一個線程來完成的。在實際開發(fā)過程中，我們當然不希望所有的任務(wù)都運行在一個線程中。

@Scheduled(cron="0/1 * * * * ? ")   //每1秒執(zhí)行一次 
public void testCron1() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每1秒執(zhí)行一次");
}

   @Scheduled(cron="0/2 * * * * ? ")   //每2秒執(zhí)行一次 
public void testCron2() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每2秒執(zhí)行一次");
}

   @Scheduled(cron="0/3 * * * * ? ")   //每3秒執(zhí)行一次 
public void testCron3() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每3秒執(zhí)行一次");
}

   @Scheduled(cron="0/4 * * * * ? ")   //每4秒執(zhí)行一次 
public void testCron4() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每4秒執(zhí)行一次");
}   

那么，怎么設(shè)計成多線程實現(xiàn)并發(fā)呢？在網(wǎng)上看到過這樣的解決方案。通過ScheduleConfig配置文件實現(xiàn)SchedulingConfigurer接口，并重寫setSchedulerfang方法，我們嘗試著配置了一下。

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

這樣就完成了多線程并發(fā)的配置？我們啟動項目通過控制臺輸出信息驗證一下結(jié)果，最后發(fā)現(xiàn)所有的任務(wù)都在同一個線程池但不同線程中完成，說明這個方案完全可行，這樣，我們就完成了spring boot 多線程并發(fā)定時任務(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ū)，一般沒有用到。

Cron表達式范例：

每隔5秒執(zhí)行一次：/5 * ?
每隔1分鐘執(zhí)行一次：0 /1 ?
每天23點執(zhí)行一次：0 0 23 ?
每天凌晨1點執(zhí)行一次：0 0 1 ?
每月1號凌晨1點執(zhí)行一次：0 0 1 1 * ?
每月最后一天23點執(zhí)行一次：0 0 23 L * ?
每周星期天凌晨1點實行一次：0 0 1 ? * L
在26分、29分、33分執(zhí)行一次：0 26,29,33 * ?
每天的0點、13點、18點、21點都執(zhí)行一次：0 0 0,13,18,21 ?

其實不會Cron表達式也不用擔心，網(wǎng)上有好多在線Cron生成器，我們完全可以通過在線生成器生成符合要求的cron，也很方便。
原文地址

有問題，請留言！

個人博客地址 https://ailijie.top/archives/...