在Spring框架中,@Scheduled
注解用于标记一个方法作为定时任务,它使用cron表达式来定义任务的执行频率。对于cron表达式定义的定时任务,如果上一个任务的执行还没有完成,下一个任务的执行行为取决于你使用的调度器(scheduler)以及任务的配置。
Spring的@Scheduled
注解默认使用的是单线程的TaskScheduler
,这意味着如果上一个任务还在执行,下一个任务的触发将会被阻塞,直到上一个任务完成。因此,在这种情况下,下一个任务不会在上一个任务还没执行完的时候就开始执行。
然而,如果你配置了多线程的TaskScheduler
,那么每个任务都会在一个独立的线程中执行。这种情况下,即使上一个任务还没有完成,下一个任务的触发也不会被阻塞,它会立即在新的线程中开始执行。
多线程的TaskScheduler设置
注意要添加注解
@Configuration @EnableAsync
@Configuration
@EnableAsync
public class TaskSchedulerConfig{@Beanpublic ThreadPoolTaskScheduler threadPoolTaskScheduler() {ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();scheduler.setPoolSize(10); // 设置线程池大小scheduler.setThreadNamePrefix("task-scheduler-"); // 设置线程名前缀scheduler.setDaemon(true); // 设置线程为守护线程scheduler.initialize(); // 初始化调度器return scheduler;}
}
由于我的是这个版本org.springframework:spring-context:5.3.17,所以这里线程池只有一个变量不太友好。
可以看看自己的版本是否支持下面的线程池
实测org.springframework:spring-context:6.0.14版本号支持下面的线程池
@Beanpublic Executor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(corePoolSize);executor.setMaxPoolSize(maxPoolSize);executor.setQueueCapacity(queueCapacity);executor.initialize();return executor;}
定时任务设置
注意要添加注解
@Async
@Component
public class TaskTest {@Async@Scheduled(cron = "* * * * * ?") // 每5秒执行一次public void reportCurrentTime() {System.out.println("Current time is: " + new Date());try {Thread.sleep(20000);} catch (InterruptedException e) {e.printStackTrace();}}
}