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

本贴转自http://www.cnblogs.com/TianFang/category/78013.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
,

0, //传递handle_timeout给的参数

delaytime,

intevaltime);

return
timerid;

}

int
close() //取消定时器

{

return
reactor()->cancel_timer(timerid);

}

//定时器回调函数

int
handle_timeout (const
ACE_Time_Value ¤t_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;

}

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