循环任务切换器 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. ICircleTaskSwitcher(循环任务切换器)来对上述例子所要求的切换器进行抽象。ICircleTaskSwitcher会在需要切换的时间点触发事件,通知预订者要切换到哪个处理器(或任务)。

      循环任务切换器的形象示意图如下:
      
 

2.适用场合:

     如果满足以下条件,则可以使用ICircleTaskSwitcher:

(1)循环的周期是一天。

(2)将一天切分为N个(N>=2)连续的时间段。

(3)需要在每个时间段的起始进行切换任务。

 

3.设计思想与实现

       ICircleTaskSwitcher的设计思路是这样的:

(1)我们可以使用前面介绍的ShortTime来记录每个发生任务切换的时间点。

(2)使用前面介绍的Circle来将所有切换的时间点组成一个“圈”,这样便可循环地取到下一个切换时刻。

(3)我们可以使用循环引擎AgileCycleEngine来对是否到达某个切换时间点进行检测。

(4)使用泛型参数来抽象切换的任务的类型。

(5)使用事件通知预订者切换时刻的到来。

ICircleTaskSwitcher的接口定义如下:

 

 

    public interface ICircleTaskSwitcher<TTask>
    {
        /// <summary>
        /// TaskDictionary key为任务的起始点(hour),value为对应的任务。
        /// </summary>
        IDictionary<ShortTime, TTask> TaskDictionary { get; set; }

        TTask CurrentTask { get; }

        void Initialize();
       
        /// <summary>
        /// TaskSwitched 当任务发生切换时,触发此事件,事件参数为刚得到控制权的任务。
        /// </summary>
        event CbGeneric<TTask> TaskSwitched;
    }

    

接口的泛型参数TTask代表任务的类型,比如缘起的例子中,该参数可以采用订单处理器接口的类型。

     TaskDictionary属性的键值即是每个切换的时间点,字典的值表示从切换时刻开始要进行的具体任务。

    当切换时刻来到时,TaskSwitched事件将被触发,事件的参数表示从该时刻起要执行的任务对象。

    关于CircleTaskSwitcher的实现要注意以下几点:

(1)Initialize方法主要做了三件事情:一是将N个切换时间点按照从小到大的顺序进行排序(因为TaskDictionary的键不一定是有序的),然后赋值给Circle,这样才能做有序的循环;二是找到当前时间所位于的时间段(因为我们可能在任何时刻启动切换器),并设置正确的当前任务;最后就初始化并启动循环引擎。

(2)在循环引擎的检测方法EngineAction中,我们首先判断是否到达了下一个切换时间点,如果是,则触发切换事件。

从CircleTaskSwitcher的源码我们看到,在有了我们前面章节介绍的CircleShortTimeAgileCycleEngine等可复用类的帮助下,CircleTaskSwitcher的实现真是相当的简洁和简单,并且每个类的概念也非常的清晰。这也就是可复用类所带来的好处的一个证明吧。

 

4. 使用时的注意事项

(1)由于循环引擎的检测时间间隔是1秒――这也是循环引擎能设置的最小检测时间间隔,所以,切换时刻不是非常精确,最多时会有1秒的误差。

(2)关于TTask泛型参数,在具体应用中,不一定非得是某个像订单处理器那样的引用类型。比如,我们希望在不同的时间段,给出的商品折扣不一样,那么,TTask完全可以是float,用来记录每个时间段具体的折扣值。
 

5.扩展

循环任务切换器ICircleTaskSwitcher暂时没有任何扩展。

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

时间: 2024-09-14 18:44:34

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

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

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

圈 Circle--ESBasic 可复用的.NET类库(03)

  1.缘起:     假设我们要开发一个多人跳棋游戏.在跳棋游戏中,当一个人走一步棋之后,控制权就轮到下一家,如此轮询,一圈之后控制权又回到自己,然后再继续轮圈下去.我们可以使用数组或列表等数据结构来解决这种转圈圈的问题,但是始终都不够直观.     我设计了Circle来对"圈"这种数据结构进行抽象,我们在类似跳棋这样的游戏中可以非常方便地直接使用它. Circle的形象示意图如下:      2.适用场合:        需要类似"圈"这样的数据结构支持的场合

时刻 ShortTime --ESBasic 可复用的.NET类库(01)

          (如果您能对照着源码来阅读本文,效果会更好.) 1.缘起:        假设我们的员工打卡系统,需要设定公司规定的上班时间.下班时间.以及还要对员工是否迟到早退等这些情况进行判断.        我们以什么方式来记录类似上下班时间这样只有时分秒没有年月日的时间了?你说可以使用DateTime,但是合适吗?总是觉得用DateTime来表示上下班的时间很别扭,因为我们的上下班时间并需要指定到具体的哪一天啊.        我设计了ESBasic.ShortTime来对类似上下班

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

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

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

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

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

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

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

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

片段整合提取器 ScatteredSegmentPicker -- ESBasic 可复用的.NET类库(21)

1.缘起:     当数据源中的数据量多到一定程度时,我们在查询时就经常使用分页策略.如果数据源是一个完整的整体,这没有什么大不了的,我们经常就在做类似的事情.但是,如果数据源不是一个完整的整体,而是由很多有序的片段构成的,并且不同的片段可能位于不同的位置(比如,位于不同的服务器节点上的内存中),甚至,每个片段内的数据还会随着时间的变化而变化的.     在这种假设的情况下,来从这个"虚拟的完整"数据源获取某个分页就不再是那么简单的事情了.一个分页可能位于一个片段的内部的某个区间,也有

工作者引擎 IWorkerEngine -- ESBasic 可复用的.NET类库(05)

1.缘起:     假设我们的系统在运行的过程中,源源不断的有新的任务需要处理(比如订单处理),而且这些任务的处理是相互独立的,没有前后顺序依赖性(顺序依赖性是指,必须在任务A处理结束后才可开始B任务),那么我们就可以使用多个线程来同时处理多个任务.每个处理任务的线程称为"工作者(线程)".      我设计了ESBasic.Threading.Engines.IWorkerEngine工作者引擎,其目的就是使用多个线程来并行处理任务,提高系统的吞吐能力.       工作者引擎的形象