@Configuration @EnableScheduling public class SchedulingConfig { }

@Scheduled使用例子

// 每天12时定时执行 @Scheduled(cron = "0 0 12 * * *") public void autoTask1() { // code ...... } // 初始化任务执行延时initialDelay毫秒，上个任务完成后，间隔fixedDelay毫秒后继续运行 @Scheduled(initialDelay = 8000, fixedDelay = 5000) public void autoTask2() { // code ...... }

@Scheduled的定义

下面具体看下@Scheduled的定义

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented @Repeatable(Schedules.class) public @interface Scheduled { String CRON_DISABLED = "-"; String cron() default ""; String zone() default ""; long fixedDelay() default -1L; String fixedDelayString() default ""; long fixedRate() default -1L; String fixedRateString() default ""; long initialDelay() default -1L; String initialDelayString() default ""; }

cron: 一个类似 cron 的表达式，扩展了通常的 UN*X 定义以包括在秒、分、小时、月中的某一天、月份和星期几的触发器。

fixedDelay: 上个任务完成后，间隔fixedDelay毫秒后继续运行

fixedDelayString: 类似fixedDelay

fixedRate: 在方法执行之间以固定时间（毫秒）段执行方法，该方式可能方法上次未执行完成，下次已开始执行。

initialDelay: 初次执行方法的延时时间，单位毫秒。

自定义任务执行线程池

查看@EnableScheduling相关源码，可以发现后台执行任务的线程池是1个线程，如果任务较多，执行时间有冲突，会造成任务的执行无法满足需求。

protected void scheduleTasks() { if (this.taskScheduler == null) { this.localExecutor = Executors.newSingleThreadScheduledExecutor(); this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor); } ...... } protected ScheduledExecutorService createExecutor( int poolSize, ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler) { //poolSize=1 return new ScheduledThreadPoolExecutor(poolSize, threadFactory, rejectedExecutionHandler); }

下面的代码就自定义了一个拥有10个线程的后台任务调度，需要创建一个TaskScheduler类型的对象即可。

@Bean("taskScheduler") public TaskScheduler taskScheduler() { ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); taskScheduler.setPoolSize(10); return taskScheduler; }