回调定时器ICallbackTimer --ESBasic 可复用的.NET类库(07)

 1.缘起:

    举个例子也许就能够说清楚回调定时器的用途。假设我的订单系统接收各种不同类型的订单,当订单A进来时,系统根据订单的类型和其它特征进行综合判断后,决定A订单要在2秒之后被方法M1处理;接下来收到的B订单经过同样的判断后,决定要在10秒后被方法M2处理,……。这时候就可以用回调定时器来管理这些将要被延迟一定时间再执行的任务。

    当然,我们可以使用定时器或前面介绍的循环引擎来实现这样的功能,只不过我们自己需要手动管理注册的定时回调任务,并且定时检查每一个未处理订单是否已经到了处理的时刻。而回调定时器已经自动帮我们做好了这些事情,而且还是一个与具体应用无关的通用组件,我们不需要再重复实现一个特定的类来做这件事情。

    回调定时器的形象示意图如下: 

     

2.适用场合:

设计回调定时器ESBasic.Threading.Timers.ICallbackTimer的主要是为了解决类似下面的问题:

(1)   任务(回调)需要被延迟某一个时间间隔后执行。

(2)不同的任务需要被延迟的时间间隔可能不同。

(3)不同的任务需要被处理的方式可能不同。

(4)回调的延迟不需要非常精确。

回调定时器要解决的最主要问题是第一点,后面两点也是回调定时器支持的重要特性。

 

3.设计思想与实现

       ICallbackTimer接口的定义如下: 

 

     /// <summary>
    /// ICallbackTimer 回调定时器。
    /// 注意:回调任务会异步在ThreadPool的WorkerThread上执行。即使目标任务抛出异常也不会影响INotifyTimer的继续运行。
    /// </summary>    
    public interface ICallbackTimer<T> : ICycleEngine
    {
        int TaskCount { get; }

        /// <summary>
        /// AddCallback 添加一个回调任务。目标任务会在spanInSecs后运行。仅仅运行一次。
        /// </summary>
        /// <param name="spanInSecs">多少秒后执行任务</param>
        /// <param name="_callback">目标方法的委托</param>
        /// <param name="_callbackPara">调用目标方法的参数</param>
        /// <returns>新的任务编号</returns>     
        int AddCallback(int spanInSecs, CbGeneric<T> _callback, T _callbackPara);

        /// <summary>
        /// RemoveCallback 删除目标回调任务。
        /// </summary>        
        void RemoveCallback(int taskID);

        /// <summary>
        /// RemoveCallbackAndAddNew 删除目标回调任务,并添加一个新的回调任务。
        /// </summary>
        int RemoveCallbackAndAddNew(int taskIDToRemoved, int spanInSecs, CbGeneric<T> _newCallback, T _newCallbackPara);
        
        /// <summary>
        /// GetLeftSeconds 离目标任务被回调执行还有多长时间(s)。返回0,表示任务不存在或者任务已经被执行。
        /// </summary>       
        int GetLeftSeconds(int taskID);

        /// <summary>
        /// Clear 清除所有回调任务。
        /// </summary>
        void Clear();
    }  

根据上述对回调定时器的描述,我们可以借助循环引擎来实现它。你已经看到,ICallbackTimer继承了ICycleEngine接口,这说明我们可以通过Start、Stop方法来控制回调定时器的运行,并通过DetectSpanInSecs属性来设置检测任务状态的时间间隔,当然,DetectSpanInSecs设置的值最好小于最小的回调任务的延迟时间间隔。

ICallbackTimer接口的泛型参数T,代表的是回调执行时所用到的参数的类型。而回调方法的签名必须是只接受一个T类型的参数,并且没有返回值(即如泛型委托CbGeneric<T>)。

AddCallback方法返回一个int,表示添加的任务的唯一编号,我们可以通过这个编号来查询该任务离被回调执行的时间(GetLeftSeconds方法),或者根据该编号来取消目标回调任务的执行(RemoveCallback方法)。

CallbackTimer实现了ICallbackTimer接口,其实现要注意以下几点:

(1)CallbackTimer继承自BaseCycleEngine,它借助于循环引擎来进行任务状态的循环检测。

(2)为了允许在多线程的环境中回调定时器,CallbackTimer必须对内部集合(dicTask)进行加锁控制。

(3)CallbackTimer使用CallbackTask类来将一个定时回调任务封装起来。

(4)回调任务是异步在后台的ThreadPool的WorkerThread上执行的。所以达到执行条件的多个回调任务不会相互阻塞,而是几乎同时执行的。

(5)在DoDetect方法的实现中,我们先拷贝一份任务列表,然后再对其作foreach,而不是直接this.dicTask.Values作foreach,这是因为,如果在某个回调执行时,调用了AddCallback/RemoveCallback将修改this.dicTask的内容,而此时对this.dicTask.Values的foreach还未结束,这时foreach将抛出异常。
 

4. 使用时的注意事项

    首先,是要注意GetLeftSeconds返回的值是不精确的。因为CallbackTimer是在每次循环检测的时候(覆写基类的DoDetect方法),修改每个CallbackTask的LeftSeconds的(通过CallbackTask的SecondsPassed方法)。所以,GetLeftSeconds方法返回的只是一个大概的而非精确的值。

    其次,回调的执行是“一次性的”,即注册的一个回调任务只会被执行一次,或者被取消。

再次,回调任务定时器允许回调任务执行时抛出异常,只不过该异常会被回调定时器忽略。所以,如果你要处理该异常,就应该在回调方法中捕获这个异常。

    最后,由于回调任务是异步在后台线程池中运行的,所以如果同时被执行的回调的任务很多,其数量超过了后台线程池中的线程数量,此时就会导致某些回调任务将会被进一步延迟执行。

 

5.扩展

       回调定时器ICallbackTimer暂时没有任何扩展。

注: ESBasic已经开源,点击这里下载源码。

 

时间: 2024-10-27 13:54:09

回调定时器ICallbackTimer --ESBasic 可复用的.NET类库(07)的相关文章

定时任务管理器 TimingTaskManager -- ESBasic 可复用的.NET类库(08)

1.缘起:     假设我们的报表系统需要在每天的00:05:00统计前一天的报表数据,需要在每周一的00:30:00统计上周的报表数据,又需要在每月1日的00:30:00统计上月的报表数据. 这些报表统计任务是很常见的系统需求,对于类似这样的在指定时刻执行的定时任务,我使用ESBasic.Threading.Timers.TimingTaskManager(定时任务管理器)来处理它. TimingTaskManager与前面讲的回调定时器CallbackTimer的区别在于,CallbackT

心跳监测器 IHeartBeatChecker -- ESBasic 可复用的.NET类库(09)

1.缘起:     假设我们的C/S系统中服务端与客户端之间采用UDP进行通信,那么服务端如何知道每个客户端当前是否仍然在线了?有可能某个客户端一直没有退出,但是在很长一段时间内都没有与服务端作任何通信,那么服务端就应该认为这个客户端已经离线了吗?为了能让服务端掌握每个客户端是否在线的状态,我们可以这样做,只要客户端一启动起来,就每隔一段时间间隔(如10秒)就向服务端发一个"我还在线"的消息,以表明自己的状态.而服务端如果在一个更大的时间间隔内(如20秒)都没有收到某个客户端的任何消息

ESBasic 可复用的.NET类库(00) -- 开源前言(附下载)

自从03年正式使用.NET开发以来,已经走过了6个年头,这期间我积累了几套类库和框架,ESBasic便是其中最基础的一个类库.ESBasic是Enterprise Service Basic的缩写,虽然也简写为ESB,但是它和Enterprise Service Bus(企业服务总线)没有任何关系.ESBasic是我能够快速和高效开发应用程序的利器之一,开这个专门的blog是想将它介绍给大家,希望能对大家有所启发. ESBasic覆盖的内容包括:对象管理.插件.网络(Socket).多线程.Em

优先级管理器 IPriorityManager -- ESBasic 可复用的.NET类库(14)

1.缘起:     假设我们的订单处理系统所要处理的订单是有优先级的,也就是说,不同的订单类型所要求被处理的紧迫程度不同,对那些优先级高的注单要先处理,对于优先级低的注单可稍后处理.对于处于同一优先级的订单了,就按照其到达的先后顺序进行处理.     这是一个典型的管理具有优先级的对象的需求,注单就是具有优先级(With Priority)的对象.我设计了ESBasic.ObjectManagement.Managers.IPriorityManager优先级管理器(确切地说,应该称之为"具有优

Round缓存管理器RoundCacheManager--ESBasic 可复用的.NET类库(26)

1.缘起:     在增量自动获取器章节的缘起部分,我们曾提到增量缓存,本节我们将深入探讨它以及用于管理增量缓存的管理器.我们还是以增量自动获取器章节提到的例子作为基础,并做更进一步的讨论.       OK,现在让我们开始这有趣的旅程. 首先,基于前面例子给出的上下文,我们知道IIncreaseAutoRetriever获取的增量是用于累积当天的已成交订单报表的."当天已成交报表"就是一个典型的增量缓存,每当有新的增量到来,都会累加到上面. 我们假设今天是2009.07.08,那么我

定时刷新缓存管理器 IRefreshableCacheManager --ESBasic 可复用的.NET类库(16)

1.缘起:     为了提升系统的性能或减轻数据库的压力等原因,我们经常在系统中使用缓存来把那些经常使用的数据保留在内存中.如果因为某些原因,缓存中这些经常使用的数据不能及时与数据源进行同步更新,那么采用定时刷新缓存中的数据有可能就是一种合适的选择.     如果你的缓存是定时刷新,那么你就需要自己为其维护一个定时器或循环引擎.如果你的系统中像这样定时刷新的缓存有多个,而且每个缓存定时刷新的时间间隔又要求不一样,那么,使这些缓存按照你预想的情况进行运转,你就需要花费一些气力.     我设计了定

循环引擎 ICycleEngine --ESBasic 可复用的.NET类库(04)

 1.缘起: 有些系统需要每隔一段时间就执行一下某个动作,比如,一个监控系统每隔10秒钟就要检测一下被监控对象的状态是否正常,那这时我们就可以用到循环引擎了.     有人说可以使用.NET框架自带定时器如System.Threading.Timer,嗯,没错.但是若这个类使用不当可能会引发后台池线程耗尽的后果.因为Timer的定时事件触发实在后台线程池中的某个线程中处理的.也就是说Timer的每次定时事件触发都会用到一个线程,如果定时的时间间隔小于事件处理的时间,则后台线程池中将会有越来越多的

循环任务切换器 CircleTaskSwitcher -- ESBasic 可复用的.NET类库(06)

 1.缘起:     假设我的订单处理系统有这样的需求:将一天24小时分为4个时段,凌晨2:15到8:30采用A类型的处理器处理接收到的订单,8:30到14:00采用B类型的处理器,14:00到20:00采用C类型的处理器,20:00到第二天凌晨2:15采用D类型的处理器.     即我们的订单处理器需要在任一天的2:15.8:30.14:00.20:00这四个时刻发生切换,这就是一个循环切换器所要做的工作.     我设计了ESBasic.Threading.Application. ICir

对象获取器IObjectRetriever -- ESBasic 可复用的.NET类库(17)

1.缘起: ESBasic中许多管理对象的容器都用到了这个ESBasic.ObjectManagement.IObjectRetriever接口,所以单独将其提出来介绍一下. 当我们向对象容器(Container)请求某个对象时,也许目标对象还未加载到容器中,这可能是因为容器在初始化的时候就没有加载这个对象,也有可能是因为这个对象是容器初始化以后新增到数据库(当然也有可能是其它的持久化存储)的.在这种情况下,对象容器就可以借助IObjectRetriever来将目标对象从数据库等持久化存储中加载