package cn.thinkpet.springbootappscaffold;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@EnableScheduling //在啟動類上加這個注解，表示開啟springboot定時任務(wù)功能
@SpringBootApplication
public class SpringbootAppScaffoldApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringbootAppScaffoldApplication.class, args);
    }
}

package cn.thinkpet.springbootappscaffold;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Slf4j
@Component
public class Test1Schedule {
    //@Scheduled注解是springboot提供的單機(jī)應(yīng)用的定時任務(wù)調(diào)度解決方案
    //cron是配置定時任務(wù)調(diào)度的 spring-cron表達(dá)式
    // spring-cron 一共可以有6個參數(shù) 以空格分開
        // 注意spring-cron 和quartz的cron不同 ,即 spring-cron不支持配置年份，沒有第7個參數(shù),
        // 如果需要指定年份的定時任務(wù)建議使用quartz,xxl-job,elastic-job這種分布式任務(wù)調(diào)度框架
    // 秒 分 時 日 月 周
    //┌───────────── second (0-59)
    // │ ┌───────────── minute (0 - 59)
    // │ │ ┌───────────── hour (0 - 23)
    // │ │ │ ┌───────────── day of the month (1 - 31)
    // │ │ │ │ ┌───────────── month (1 - 12) (or JAN-DEC)
    // │ │ │ │ │ ┌───────────── day of the week (0 - 7)
    // │ │ │ │ │ │          (0 or 7 is Sunday, or MON-SUN)
    // │ │ │ │ │ │
    // * * * * * *
//    @Scheduled(cron = "0 41 21 * * ?")   // 定點(diǎn)--21點(diǎn)41分0秒 執(zhí)行
//    @Scheduled(cron = "*/1 * * * * ?") //定頻--每1秒執(zhí)行1次
    // 0 0 0 ? * MON#1  每月第一個星期一的零點(diǎn)0分0秒
    // 0 0 0 ? * 5#2  每月第2個星期五的零點(diǎn)0分0秒
    // 0 0 0 L * *    每月最后一天的零點(diǎn)0分0秒
    // 0 0 0 * * 5L   每月最后一個星期五的零點(diǎn)0分0秒
    //spring-cron表達(dá)式 值的常用通配符：
    //  *：表示所有值 比如用在日 表示每一天。
    //  ?：表示不指定值 比如周配置  表示不指定星期幾執(zhí)行。
    //   /：表示遞增觸發(fā) 比如  用在分 5/20 從第五分鐘開始 每增加20分鐘執(zhí)行一次。
    //   -：表示區(qū)間 比如用在 1-6  表示一月到六月執(zhí)行
    //   # :表示每月中的第幾個星期幾。5#2：表示每月第2個星期五。MON#1：表示每月第1個星期一
    //  L :表示最后，比如每月最后一個星期天
    //其他通配符可以查詢官方文檔
    //https://docs.spring.io/spring-framework/reference/integration/scheduling.html#scheduling-cron-expression
    @Scheduled(cron = "0/1 * * * * ?")
    public void singleTaskTest1() throws InterruptedException {
        log.info("singleTaskTest1");
    }
    @Scheduled(cron = "0/1 * * * * ?")
    public void singleTaskTest2() throws InterruptedException {
        log.info("singleTaskTest2");
    }
//    @Scheduled(cron = "0/1 * * * * ?")
    @Scheduled(cron = "${test3.cron:0/2 * * * * ?}")
    //從yml或properties配置文件中讀取 cron 值,讀不到時使用默認(rèn)的 0/2 * * * * ?
    public void singleTaskTest3() throws InterruptedException {
        log.info("singleTaskTest3");
//        LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(3));
    }
    //----------如果嫌配置cron表達(dá)式麻煩，可以使用如下的固定速度+固定延期 的方式來配置定時任務(wù)-----------
    //    @Scheduled(initialDelay = 3000,fixedRate = 5000)
    //initialDelay表示第一次延遲多少毫秒執(zhí)行，單位是毫秒
    //fixedRate表示多久執(zhí)行一次，單位是毫秒
    @Scheduled(initialDelay = 3000,fixedRate = 5000) //第一次延遲3秒執(zhí)行,后面間隔5秒執(zhí)行一次
    public void singleTaskTest4() throws InterruptedException {
        log.info("singleTaskTest4");
    }
}

server.port=8080
#配置singleTaskTest3的cron表達(dá)式
test3.cron=0/7 * * * * ?

package cn.thinkpet.springbootappscaffold;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
/**
 * 為了實(shí)現(xiàn)springboot 多個定時任務(wù)調(diào)度 之間的并發(fā)執(zhí)行，
 * 需要重寫 調(diào)度器使用的 ThreadPoolTaskScheduler
 */
@Configuration
public class MyScheduledConfig implements SchedulingConfigurer {
    /**
     * 定義springboot定時任務(wù)的 --- 線程池大小
     */
    private static final int POOL_SIZE = 6;
    /**
     * 定義springboot定時任務(wù)的 ---自定義線程名前綴
     */
    private static final String TASK_THREAD_PREFIX = "my-sche-task-";
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //需要創(chuàng)建1個springboot提供的ThreadPoolTaskScheduler
        ThreadPoolTaskScheduler bootScheduleExecutor = new ThreadPoolTaskScheduler();
        //配置這個springboot項(xiàng)目全部定時任務(wù)使用 的線程數(shù)是 POOL_SIZE
        //在實(shí)際應(yīng)用中需要考慮實(shí)際任務(wù)數(shù)量，創(chuàng)建相應(yīng)大小的線程池
        bootScheduleExecutor.setPoolSize(POOL_SIZE);
        //配置線程名前綴
        bootScheduleExecutor.setThreadNamePrefix(TASK_THREAD_PREFIX);
        //初始化線程池執(zhí)行器
        bootScheduleExecutor.initialize();
        //設(shè)置 調(diào)度器使用 bootScheduleExecutor
        taskRegistrar.setTaskScheduler(bootScheduleExecutor);
    }
}