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,
            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;
}
代码功能比较简单，这里就不多做介绍了。