ACE学习之定时器(Timer)

时间：2010-06-07 来源：LaoLiulaoliu

转载自：http://blog.csdn.net/wj4064/archive/2008/04/03/2247752.aspx 听陆凯说ACE的定时器有绝对和相对定时的概念，于是想看看究竟。ACE反应器的schedule_timer函数是相对现在起定时的，Thread_Timer_Queue_Adapter的schedule函数是从函数gettimeofday的时间开始定时的(也可在此基础上加减)。原来定时的相对和绝对的概念是对于第一次超时的，跟重置无关。重置还是固定的间隔，如果执行handle_timeout超过重置的时间，则重置好像被忽略似的一直执行handle_timeout函数的内容。定时器(Timer)

在事件超时的时候适当的调用事件处理器的handle_timeout()方法.为调度这样的定时器,反应器拥有一个schedule_timer()的方法.该方法接受事件处理器,以及以ACE_Time_Value对象形式出现的延迟对味参数.此外,可以指定时间间隔,使定时器在它超时后自动恢复 . 反应器在内部维护ACE_Timer_Queue，它以定时器要被调度的顺序对它们进行维护。实际使用的用于保存定时器的数据结构可以通过反应器的set_timer_queue()方法进行改变。反应器有若干不同的定时器结构可用，包括定时器轮（timer wheel）、定时器堆（timer heap）和哈希式定时器轮（hashed timer wheel）。设置定时器:

#include "ace/Time_Value.h"

#include "ace/Log_Msg.h"

#include "ace/Synch.h"

#include "ace/Reactor.h"

#include "ace/Event_Handler.h"

class wjtimer : public ACE_Event_Handler

{

public:

virtual int handle_timeout(const ACE_Time_Value &current_time,

const void *act /* = 0 */)

{

const int *num = ACE_static_cast(const int*,act);

ACE_DEBUG((LM_DEBUG, ACE_TEXT("%d "),num));

return 0;

}

protected:

private:

};

int Start()

{

wjtimer *timer = new wjtimer;

ACE_Time_Value tv(5),tv2(3);

ACE_Reactor::instance()->schedule_timer(timer,(const int*)44,tv,tv2);

while(1)

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

return 0;

}

Wjtimer的handle_timeout用来处理定时器到期的函数,schedule_timer传入一个事件处理器的句柄,参数,开始延迟时间和恢复时间.它返回一个唯一的定时器标识符.

ACE提供了一组主动的定时器队列类,它不仅封装了基于OS的定时器机制,还会在自己私有的控制线程中运行定时器事件循环,所以叫主动定时器队列. 定义: typedef ACE_Thread_Timer_Queue_Adapter<ACE_Timer_Heap>ActiveTimer, ActiveTimer适配器允许你指定任何一种具体的定时器队列,充当主动定时器的底层定时器队列.

#include "ace/Time_Queue_Adapters.h"

#include "ace/Timer_Heap.h"

#include "ace/Timer_Wheel.h"

//typedef ACE_Thread_Timer_Queue_Adapter<ACE_Timer_Wheel>ActiveTimer,

#include "ace/Event_Handler.h"

class CBB : public ACE_Event_Handler

{

private:

int id_;

public:

CBB(int id) : id_(id){}

virtual int handle_timeout(const ACE_Time_Value &current_time,