解析spring schedule 任务调度
2013-06-19 12:41
183 查看
Spring在schedule这块支持JDK Timer、concurrent、quartz三种,这三种任务调度方案在实现机制和调用方法上都不同,但spring通过对其包装,使得基于spring能用统一的配置和编码风格来使用这三种schedule方案。
总得来说这三种schedule都是基于scheduler->trigger->job的基本流程,因此spring通过TimerFactoryBean、ScheduledExecutorFactoryBean和SchedulerFactoryBean分别实现JDK Timer、concurrent和quartz的基本流程。主要逻辑如下代码所示:
TimerFactoryBean
[java]
view plaincopyprint?
public void afterPropertiesSet() {
logger.info("Initializing Timer");
this.timer = createTimer(this.beanName, this.daemon);
// Register specified ScheduledTimerTasks, if necessary.
if (!ObjectUtils.isEmpty(this.scheduledTimerTasks)) {
//注册task和timer registerTasks(this.scheduledTimerTasks, this.timer);
}
}
SchedulerFactoryBean
[c-sharp]
view plaincopyprint?
public void afterPropertiesSet() throws Exception {
.....
// 初始化sceduler
initSchedulerFactory(schedulerFactory);
this.scheduler = createScheduler(schedulerFactory, this.schedulerName);
//注册listener、trigger和job
registerListeners();
registerJobsAndTriggers();
......
//启动scheduler
startScheduler(this.scheduler, this.startupDelay);
......
}
}
public void afterPropertiesSet() throws Exception {
.....
// 初始化sceduler
initSchedulerFactory(schedulerFactory);
this.scheduler = createScheduler(schedulerFactory, this.schedulerName);
//注册listener、trigger和job
registerListeners();
registerJobsAndTriggers();
......
//启动scheduler
startScheduler(this.scheduler, this.startupDelay);
......
}
}
顺着scheduler->trigger->job的思路,Spring又分别对JDK Timer、concurrent、quartz的trigger进行了封装,暴露出时间调度的配置参数,三种封装类分别为ScheduledTimerTask、ScheduledExecutorTask和CronTriggerBean+SimpleTriggerBean。三种trigger封装类分别根据实现机制的特点暴露出时间调度配置并串联起scheduler和具体job任务
总得来说这三种schedule都是基于scheduler->trigger->job的基本流程,因此spring通过TimerFactoryBean、ScheduledExecutorFactoryBean和SchedulerFactoryBean分别实现JDK Timer、concurrent和quartz的基本流程。主要逻辑如下代码所示:
TimerFactoryBean
[java]
view plaincopyprint?
public void afterPropertiesSet() {
logger.info("Initializing Timer");
this.timer = createTimer(this.beanName, this.daemon);
// Register specified ScheduledTimerTasks, if necessary.
if (!ObjectUtils.isEmpty(this.scheduledTimerTasks)) {
//注册task和timer registerTasks(this.scheduledTimerTasks, this.timer);
}
}
[c-sharp] view plaincopyprint? public void afterPropertiesSet() { if (logger.isInfoEnabled()) { logger.info("Initializing ScheduledExecutorService" + (this.beanName != null ? " '" + this.beanName + "'" : "")); } ScheduledExecutorService executor = createExecutor(this.poolSize, this.threadFactory, this.rejectedExecutionHandler); // Register specified ScheduledExecutorTasks, if necessary. if (!ObjectUtils.isEmpty(this.scheduledExecutorTasks)) { registerTasks(this.scheduledExecutorTasks, executor); } // Wrap executor with an unconfigurable decorator. this.executor = (this.exposeUnconfigurableExecutor ? Executors.unconfigurableScheduledExecutorService(executor) : executor); } public void afterPropertiesSet() { if (logger.isInfoEnabled()) { logger.info("Initializing ScheduledExecutorService" + (this.beanName != null ? " '" + this.beanName + "'" : "")); } ScheduledExecutorService executor = createExecutor(this.poolSize, this.threadFactory, this.rejectedExecutionHandler); // Register specified ScheduledExecutorTasks, if necessary. if (!ObjectUtils.isEmpty(this.scheduledExecutorTasks)) { registerTasks(this.scheduledExecutorTasks, executor); } // Wrap executor with an unconfigurable decorator. this.executor = (this.exposeUnconfigurableExecutor ? Executors.unconfigurableScheduledExecutorService(executor) : executor); }
SchedulerFactoryBean
[c-sharp]
view plaincopyprint?
public void afterPropertiesSet() throws Exception {
.....
// 初始化sceduler
initSchedulerFactory(schedulerFactory);
this.scheduler = createScheduler(schedulerFactory, this.schedulerName);
//注册listener、trigger和job
registerListeners();
registerJobsAndTriggers();
......
//启动scheduler
startScheduler(this.scheduler, this.startupDelay);
......
}
}
public void afterPropertiesSet() throws Exception {
.....
// 初始化sceduler
initSchedulerFactory(schedulerFactory);
this.scheduler = createScheduler(schedulerFactory, this.schedulerName);
//注册listener、trigger和job
registerListeners();
registerJobsAndTriggers();
......
//启动scheduler
startScheduler(this.scheduler, this.startupDelay);
......
}
}
顺着scheduler->trigger->job的思路,Spring又分别对JDK Timer、concurrent、quartz的trigger进行了封装,暴露出时间调度的配置参数,三种封装类分别为ScheduledTimerTask、ScheduledExecutorTask和CronTriggerBean+SimpleTriggerBean。三种trigger封装类分别根据实现机制的特点暴露出时间调度配置并串联起scheduler和具体job任务
相关文章推荐
- 目前的定时调度都用Spring Schedule 任务调度实现
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- Spring Schedule 任务调度实现
- spring batch schedule(任务调度)值cron 表达式
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- spring定时任务如何运行 schedule解析
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- spring boot 自学笔记(六) Schedule调度任务
- 06 Spring 异步执行,任务调度(@Schedule、@Async)
- Uncode-Schedule首页、文档和下载 - 分布式任务调度组件 - 开源中国社区
- Spring任务调度实战之Quartz Simple Trigger
- Spring结合任务调度quartz
- Spring任务调度之quartz