spring定时器原理是什么?

XIAO 2020-06-13 21:15:58 java常见问答 7187

作为程序员来说,我们可能经常会使用到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架构师信息,记得关注本站消息哦。

推荐阅读:

spring全家桶是什么?spring全家桶要学些什么?

spring定时器注解如何配置?如何使用?

spring ioc容器是什么?有什么作用?