1、启用定时任务

在启动类上添加注解@EnableScheduling

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

2、创建定时任务配置类

@Component
@Slf4j
public class ScheduleTask {
    /**
     * cron表达式
     * 每3秒执行一次
     */
    @Scheduled(cron = "*/3 * * * * ?")
    public void run1() {
        log.info("======cron======");
    }

    /**
     * 启动后10秒开始执行，固定5秒周期执行一次
     */
    @Scheduled(initialDelay = 10000, fixedRate = 5000)
    public void run2() {
        log.info("======fixedRate======");
    }

    /**
     * 启动后10秒开始执行，距离上次执行结束之后20秒再开始执行下一次
     */
    @Scheduled(initialDelay = 10000, fixedDelay = 20000)
    public void run3() {
        log.info("======fixedDelay======");
    }
}

主要有3种方式设置执行周期：

cron表达式：最灵活的方式，可以根据表达式设定执行时间。
fixedRate：固定周期执行，执行周期 = max(fixedRate, 业务代码执行耗时)。
fixedDelay：上一次执行结束之后开始计时，执行周期 = fixedDelay + 业务代码执行耗时。

3、异步执行定时任务

如果在定时任务多，业务执行时间比较长的情况下，如果使用同步处理，就会发生定时任务不能及时执行的情况。就需要用到异步机制来执行定时任务。

3.1、配置异步任务的线程池

@Bean
public Executor taskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(20);
    executor.setMaxPoolSize(50);
    executor.setQueueCapacity(200);
    executor.setKeepAliveSeconds(60);
    executor.setThreadNamePrefix("scheduleTask-");
    executor.setAwaitTerminationSeconds(60 * 5);
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    return executor;
}

3.2、启动类添加`@EnableAsync`注解

@SpringBootApplication
@EnableScheduling
@EnableAsync
public class TaskApplication {
    public static void main(String[] args) {
        SpringApplication.run(TaskApplication.class, args);
    }
}

最后在需要异步执行的定时任务方法或类上添加@Async注解即可生效。

SpringBoot定时任务实现(二)