作为程序员来说,我们可能经常会使用到spring框架去实现各种各样的需求开发,其中的一项,定时器也是经常会被使用到的,那么你是否清楚其原理是什么呢?
首先我们来看看简单定时器实现方法:用ScheduledExecutorService接口的方式实现:
public interface ScheduledExecutorService extends ExecutorService { //创建并执行在给定延迟后启用的一次性操作。 ScheduledFuture < ? > schedule(Runnable command, long delay, TimeUnit unit); 创建并执行在给定延迟后启用的 ScheduledFuture。 < V > ScheduledFuture < V > schedule(Callable < V > callable, long delay, TimeUnit unit); //创建并执行一个在给定初始延迟后首次启用的定期操作, 后续操作具有给定的周期; //也就是将在 initialDelay 后开始执行, 然后在 initialDelay + period 后执行, //接着在 initialDelay + 2 * period 后执行, 依此类推。 如果任务的任何一个执行遇到异常, 则后续执行都会被取消。 // 否则, 只能通过执行程序的取消或终止方法来终止该任务。 如果此任务的任何一个执行要花费比其周期更长的时间, 则将推迟后续执行, 但不会同时执行。 ScheduledFuture < ? > scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit); //创建并执行一个在给定初始延迟后首次启用的定期操作, 随后, 在每一次执行终止和下一次执行开始之间都存在给定的延迟。 如果任务的任一执行遇到异常, 就会取消后续执行。 否则, 只能通过执行程序的取消或终止方法来终止该任务。 ScheduledFuture < ? > scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit); }
用法示例如下:
import static java.util.concurrent.TimeUnit.*; class BeeperControl { private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); public void beepForAnHour() { final Runnable beeper = new Runnable() { public void run() { System.out.println("beep"); } }; final ScheduledFuture < ? > beeperHandle = scheduler.scheduleAtFixedRate(beeper, 10, 10, SECONDS); scheduler.schedule(new Runnable() { public void run() { beeperHandle.cancel(true); } }, 60 * 60, SECONDS); } }
具体说明如下所示:
ScheduledAnnotationBeanPostProcessor
其核心方法是,Object postProcessAfterInitialization(final Object bean, String beanName) ,其主要功能是负责@Schedule注解的扫描,构建ScheduleTask 。
其核心方法是,onApplicationEvent(ContextRefreshedEvent event)
其功能是,在spring容器加载完毕之后调用,ScheduleTask向ScheduledTaskRegistrar中注册, 调用ScheduledTaskRegistrar.afterPropertiesSet() 。
ScheduledTaskRegistrar
其核心方法是,void afterPropertiesSet(),功能就是初始化所有定时器,并且启动定时器 。
TaskScheduler
主要的实现类有三个,它们分别是ThreadPoolTaskScheduler, ConcurrentTaskScheduler和TimerManagerTaskScheduler 。
这些类的作用最主要是将task和executor使用ReschedulingRunnable包装起来并且进行了生命周期管理。
其核心方法是,ScheduledFuture schedule(Runnable task, Trigger trigger) 。
那么以上就是有关spring定时器原理的所有内容了,还想了解更多的java架构师信息,记得关注本站消息哦。
推荐阅读: