ACE反应器(Reactor)模式(4)

转载于：http://www.cnblogs.com/TianFang/archive/2006/12/18/596012.html

定时器的实现

通过Reactor机制，还可以很容易的实现定时器的功能，使用方式如下。

编写一个事件反应器，重载handle_timeout()方法，该方法是定时器的触发时间到时，会自动触发该方法。
通过Reactor的schedule_timer()方法注册定时器。
启动reacotr的handle_events()事件分发循环。
当不想使用定时器时，可以通过Reactor的cancel_timer()方法注销定时器。

下面的代码简单的实现了一个定时器，并具有基本的开启，关闭功能。

 #include <ace/OS.h>

 #include <ace/Reactor.h>

 class MyTimerHandler : public ACE_Event_Handler

 {

 private:

     int inteval;    //执行时间间隔

     int delay;        //延迟执行时间

     int timerid;

 public:

     MyTimerHandler(int delay,int inteval)

     {

         this->delay=delay;

         this->inteval=inteval;

     }

     int open()    //注册定时器

     {

         ACE_Time_Value delaytime(inteval);

         ACE_Time_Value intevaltime(inteval);

         timerid = reactor()->schedule_timer(this,

             ,    //传递handle_timeout给的参数

             delaytime,

             intevaltime);

         return timerid;

     }

     int close()    //取消定时器

     {

         return reactor()->cancel_timer(timerid);

     }

     //定时器回调函数

     int handle_timeout (const ACE_Time_Value &current_time,

         const void * = )

     {

         time_t epoch = ((timespec_t)current_time).tv_sec;

         ACE_DEBUG ((LM_INFO,

             ACE_TEXT ("handle_timeout: %s\n"),

             ACE_OS::ctime (&epoch)));

         return ;

     }

 };

 int main(int argc, char *argv[])

 {

     MyTimerHandler * timer = new MyTimerHandler (,);

     timer->reactor(ACE_Reactor::instance());

     timer->open();

     for(int i=;i<;i++)    //触发次handle_timeout事件

     {

         ACE_OS::printf("\n%d\n",i);

         ACE_Reactor::instance()->handle_events();

     }

     timer->close();

     ACE_OS::printf("cancel timer");

     while(true)

         ACE_Reactor::instance()->handle_events();

     return ;

 }

代码功能比较简单，这里就不多做介绍了。