一。Spring提供了两种调度任务的方式。
调度任务，@Scheduled
异步任务，@Async
1）spring的定时任务默认是单线程，多个任务执行起来时间会有问题。
2）不论定时任务被安排在多少个class类中，其依然是单线程执行定时任务（串行任务）。
3）定时任务并行处理，需手动配置。
4）有多个web容器实例，scheduler会在多个实例上同时运行。
5）shedule流程初始化。
首先spring容器初始化-->通过反射bean初始化之后-->对实例化的bean进行class上的注解扫描-->判断class中是否有@Scheduled注解-->若有则判断调度的模式--> ScheduledAnnotationBeanPostProcessor处理，将扫描到的@Scheduled方法封装成Runnable，交给线程池(默认单线程)执行。
6）定时任务的方法中，一定不要出现“死循环”、“http持续等待无响应”现象，否则会导致定时任务程序无法正常。
1，定时任务单线程执行的时间问题。
1）bTask会因为aTask的sleep(20)而延迟执行。
@Component
public class TestTask {
@Scheduled(fixedRate = 1000 * 10) //每10秒执行一次
public void aTask(){
try {
TimeUnit.SECONDS.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println(sdf.format(DateTime.now().toDate())+"*********A任务每10秒执行一次进入测试");
}
}
@Component
public class TestTask2 {
@Scheduled(fixedRate = 5000) //每5秒执行一次
public void bTask(){
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println(sdf.format(DateTime.now().toDate())+"*********B任务每5秒执行一次进入测试");
}
}
2）实现SchedulingConfigurer和AsyncConfigurer配置线程池。
@Configuration
@EnableAsync
@EnableScheduling
public class AppConfig {
}
@Configuration//配置定时任务的线程池，支持定时任务并行处理
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(taskExecutor());
}
@Bean(destroyMethod="shutdown")
public Executor taskExecutor() {
return Executors.newScheduledThreadPool(100);
}
}
@Configuration
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(7);
executor.setMaxPoolSize(42);
executor.setQueueCapacity(11);
executor.setThreadNamePrefix("MyExecutor-");
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}
二，用法解释
1，@Scheduled注解，添加到方法上，周期性的调用该方法
简单的周期性的任务simple periodic scheduling
image.png
1）initialDelay: 第一次执行方法需要等待时间，单位为毫秒ms。the number of milliseconds to wait before the first execution of the method.
(一般来说，不加该参数，项目重启，就会立刻执行该方法。)
@Scheduled(initialDelay=1000, fixedRate=5000)
public void doSomething() {
// something that should execute periodically
}
2）fixedDelay: 固定的延迟后再次调用。当方法第一次被调用结束后，延迟固定的ms后，再次调用。
from the completion time of each preceding invocation.从上次调用的完成时间起。
@Scheduled(fixedDelay=5000)
public void doSomething() {
// something that should execute periodically
}
3）fixedRate 方法每fixedRate毫秒，将被调用一次，不管上次是否结束。
would be executed every fixedRate ms
@Scheduled(fixedRate=5000)
public void doSomething() {
// something that should execute periodically
}
2，cron表达式。
1）cron表达式， 使用6 - 7 个域
Seconds(秒) Minutes(分) Hours(时) DayOfMonth(第几日) Month(月) DayOfWeek(星期几, 1=星期天，2=星期一) Year(年，可选)
*：表示匹配该域的任意值
,逗号： 指定触发
-：范围触发
/：步进触发。
2）eg:
"0 0-5 14 * * ?" 在每天下午2点到下午2:05范围内，每1分钟触发 一次
"0 0/5 14,18 * * ?" 指定小时14，18点，指定步进值5分钟，在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发一次。
@Scheduled(cron="*/5 * * * * MON-FRI")
public void doSomething() {
// something that should execute on weekdays only
}
三，配置定时任务的线程池。
1）配置scheduledThreadPool
public class AppConfig implements SchedulingConfigurer{
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
logger.info("Configure task registor: {}", taskRegistrar);
taskRegistrar.setScheduler(taskExecutor());
}
@Bean(destroyMethod="shutdown")
public Executor taskExecutor() {
return Executors.newScheduledThreadPool(20);
}
}
2）定时任务中使用hibernate操作。no hibernate session bound to thread
需要在service层添加@Transactional注解。
@Scheduled 标注的方法最后是包装到 ScheduledMethodRunnable 中被执行的，它是一个 Runnable 接口的实现
没有添加事务支持，就不能从线程资源中获取Session
