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

定时器的实现

通过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 * = 0) { time_t epoch = ((timespec_t)current_time).tv_sec; ACE_DEBUG ((LM_INFO,ACE_TEXT ("handle_timeout: %s/n"),ACE_OS::ctime (&epoch))); return 0; } };

int main(int argc,char *argv[]) { MyTimerHandler * timer = new MyTimerHandler (3,5); timer->reactor(ACE_Reactor::instance()); timer->open();

for(int i=0;i<2;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 0; }

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