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

本贴转自http://www.cnblogs.com/TianFang/category/78013.html 作者:天方

定时器的实现

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

1. 编写一个事件反应器，重载 handle_timeout() 方法，该方法是定时器的触发时间到时，会自动触发该方法。
2. 通过Reactor的 schedule_timer() 方法注册定时器。
3. 启动reacotr的 handle_events() 事件分发循环。
4. 当不想使用定时器时，可以通过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,
0,//传递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;
}

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!