.NET框架中的可复用类库ESBasic

1.缘起：

创新互联建站专业IDC数据服务器托管提供商，专业提供成都服务器托管，服务器租用，成都IDC机房托管，成都IDC机房托管，成都多线服务器托管等服务器托管服务。

有些系统需要每隔一段时间就执行一下某个动作，比如，一个监控系统每隔10秒钟就要检测一下被监控对象的状态是否正常，那这时我们就可以用到循环引擎了。

有人说可以使用.NET框架自带定时器如System.Threading.Timer，嗯，没错。但是若这个类使用不当可能会引发后台池线程耗尽的后果。因为Timer的定时事件触发实在后台线程池中的某个线程中处理的。也就是说Timer的每次定时事件触发都会用到一个线程，如果定时的时间间隔小于事件处理的时间，则后台线程池中将会有越来越多的线程被Timer使用掉，直至线程池中再无空闲的线程。

而ESBasic.Threading.Engines.ICycleEngine的设计目标是永远都只使用一个线程。比如，它会隔10秒执行一个Action，执行完后再隔10秒再执行Action。间隔时间的等待与Action的执行都是在同一个线程中处理的。

2.适用场合：

根据上面的描述你应该已经看到了ICycleEngine与Timer之间的区别。由于Action的执行会占用额外的时间，所以ICycleEngine不适合于精确定时的任务。比如上面的例子，下一个Action开始的时刻与上一个Action开始的时刻的真正的时间差可能是12秒，而不是10秒，因为上一个Action的执行花费了2秒。

所以，如果你的系统不需要精确的定时任务，而且又不想花费过多的精力去防范使用Timer时线程耗尽的窘境出现，那么ICycleEngine将是个不错的选择。

3．设计思想与实现

ICycleEngine接口的源码如下：   

 
 
 
    
  
  
  
  1. ///   
    2.   
  
  
  2. /// ICycleEngine 在后台线程中进行间隔循环的引擎  
    3.   
  
  
  3. /// zhuweisky 2006.12.21  
    4.   
  
  
  4. ///   
    5.   
  
  
  5. public interface ICycleEngine  
    6.   
  
  
  6. {  
    7.   
  
  
  7.     ///   
    8.   
  
  
  8.     /// Start 启动后台引擎线程  
    9.   
  
  
  9.     ///   
    10.   
  
  
  10.     void Start();  
    11.   
  
  
  11.  
    12.   
  
  
  12.     ///   
    13.   
  
  
  13.     /// Stop 停止后台引擎线程，只有当线程安全退出后，该方法才返回  
    14.   
  
  
  14.     ///   
    15.   
  
  
  15.     void Stop();  
    16.   
  
  
  16.  
    17.   
  
  
  17.     ///   
    18.   
  
  
  18.     /// IsRunning 引擎是否运行中  
    19.   
  
  
  19.     ///   
    20.   
  
  
  20.     bool IsRunning { get; }  
    21.   
  
  
  21.  
    22.   
  
  
  22.     ///   
    23.   
  
  
  23.     /// DetectSpanInSecs 引擎进行轮询的间隔，DetectSpanInSecs=0，表示无间隙运作引擎；DetectSpanInSecs小于0则表示不使用引擎  
    24.   
  
  
  24.     ///   
    25.   
  
  
  25.     int DetectSpanInSecs { get;set; }  
    26.   
  
  
  26.  
    27.   
  
  
  27.     ///   
    28.   
  
  
  28.     /// OnEngineStopped 当引擎由运行变为停止状态时，将触发此事件。如果是异常停止，则事件参数为异常对象，否则，事件参数为null。  
    29.   
  
  
  29.     ///   
    30.   
  
  
  30.     event CbException OnEngineStopped;  
    31.   
  
  
  31. }  
    32.

如何实现这个接口了？

由于不同的系统要求执行的Action不一样，所以，我们可以实现一个abstract基类BaseCycleEngine来保证循环引擎的正常运转，而派生类只要override基类的abstract方法DoDetect来执行自己的Action。

关于BaseCycleEngine的实现要注意以下几点：

（1）循环引擎是在后台线程池的某个线程上运行的。

（2）循环引擎可以无限次的启动、停止、启动、停止……

（3）为了保证调用Stop方法时能迅速地停止引擎，我将间隔时间划分为多个BaseCycleEngine.SleepTime。而不是一次性地Sleep间隔时间。

（4）为了保证循环引擎真正停止后，才返回Stop方法的调用，我使用了ManualResetEvent来进行控制。

（5）DoDetect方法的返回值为false，则表示在该Action执行完后将停止循环引擎。此后，可以重新调用Start方法再次启动循环引擎。

4. 使用时的注意事项

（1）     要确保我们的Action（即派生类的DoDetect方法）不任何抛出异常，否则会导致循环引擎异常停止，并导致循环引擎的内部状态损坏而不可用。所以在派生类的DoDetect方法方法实现时捕捉所有的异常并加以处理。

（2）     在DoDetect方法实现中不能调用Stop方法，否则会导致死锁出现。

（3）     如果将DetectSpanInSecs设为0，则表示无间隙的执行DoDetect方法。而如果将DetectSpanInSecs设为负数，则表示不启动循环引擎。

（4）     当引擎已经启动并正在运行的过程中，如果要改变DetectSpanInSecs的值并使其生效，则必须重新启动（先调用Stop方法再调用Start方法）引擎才可。

5.扩展

（1）AgileCycleEngine

在上面的介绍中，我们都是以DoDetect方法来表示要执行的Action，而且我们必须以继承BaseCycleEngine的方式来使用循环引擎，这无疑限制了循环引擎的使用。

AgileCycleEngine的存在便是为了突破这个限制。

 
 
 
    
  
  
  
  1. public sealed class AgileCycleEngine :BaseCycleEngine  
    2.   
  
  
  2. {  
    3.   
  
  
  3.     private IEngineActor engineActor;  
    4.   
  
  
  4.  
    5.   
  
  
  5.     public AgileCycleEngine(IEngineActor _engineActor)  
    6.   
  
  
  6.     {  
    7.   
  
  
  7.         this.engineActor = _engineActor;  
    8.   
  
  
  8.     }  
    9.   
  
  
  9.  
    10.   
  
  
  10.     protected override bool DoDetect()  
    11.   
  
  
  11.     {  
    12.   
  
  
  12.         return this.engineActor.EngineAction();  
    13.   
  
  
  13.     }  
    14.   
  
  
  14. }  
    15.

AgileCycleEngine继承自BaseCycleEngine，但是它是非abstract的。AgileCycleEngine通过组合而非继承的方式来使用循环引擎，我们可以将Action的执行者抽象为一个接口IEngineActor。

 
 
 
    
  
  
  
  1. public interface IEngineActor  
    2.   
  
  
  2. {  
    3.   
  
  
  3.     ///   
    4.   
  
  
  4.     /// EngineAction 执行引擎动作，返回false表示停止引擎。  
    5.   
  
  
  5.     /// 注意，该方法不能抛出异常，否则会导致引擎停止运行（循环线程遭遇异常退出）。  
    6.   
  
  
  6.     ///          
    7.   
  
  
  7.     bool EngineAction() ;  
    8.   
  
  
  8. } 
    9.

通过实现IEngineActor来表明我们要执行的Action，然后将其注入到AgileCycleEngine中。

（2）永不停止的循环引擎

我们再考虑一个扩展的情况，假设我们的系统要求在启动时就将引擎运行起来，而且在整个运行的生命周期中，都不需要停止引擎，那么我们可能不想将Start方法、Stop方法暴露出来以免意外的调用Stop方法而导致引擎停止运行，那这个时候我们可以使用类似下面的技巧来做到：

 
 
 
    
  
  
  
  1. public sealed class MyCircleEngine : IEngineActor  
    2.   
  
  
  2. {  
    3.   
  
  
  3.     private AgileCycleEngine agileCycleEngine;  
    4.   
  
  
  4.     public void Initialize()  
    5.   
  
  
  5.     {  
    6.   
  
  
  6.         this.agileCycleEngine = new AgileCycleEngine(this);  
    7.   
  
  
  7.         this.agileCycleEngine.DetectSpanInSecs = 10;  
    8.   
  
  
  8.         this.agileCycleEngine.Start();  
    9.   
  
  
  9.     }  
    10.   
  
  
  10.     #region IEngineActor 成员  
    11.   
  
  
  11.     public bool EngineAction()  
    12.   
  
  
  12.     {  
    13.   
  
  
  13.         // My Action  
    14.   
  
  
  14.         return true;  
    15.   
  
  
  15.     }  
    16.   
  
  
  16.     #endregion  
    17.   
  
  
  17. } 
    18.

用于示例的MyCycleEngine内部使用了AgileCycleEngine，但它没有暴露循环引擎的任何控制方法，而且Initialize方法表明MyCycleEngine只要一初始化便开始运行，而且没有办法让其停止运行。MyCycleEngine实现了IEngineActor接口，并把自己注入到AgileCycleEngine类型的成员中，于是引擎将每隔10秒钟执行一次MyCycleEngine的EngineAction方法。

网站栏目：.NET框架中的可复用类库ESBasic
URL地址：http://www.36103.cn/qtweb/news23/4123.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

面包屑导航知识

各行业网站

网站制作　　 　网络营销公司　　 　水泥基自流平　　 　店面门头广告　　 　橡塑保温管　　 　宜宾网站建设　　 　品牌网站建设公司　　 　成都定制网站建设　　 　达州主机托管　　 　古蔺网站建设　　 　证企宝企业服务　　 　响应式网站设计　　 　娃娃鱼鱼苗　　 　成都展柜制作　　 　品牌网站建设　　 　棕树数据中心　　 　雅安电信机房　　 　瑞杰企业管理　　 　高端网站建设　　 　手机网站制作