Chinaunix首页 | 论坛 | 博客
  • 博客访问: 832346
  • 博文数量: 330
  • 博客积分: 9641
  • 博客等级: 中将
  • 技术积分: 3181
  • 用 户 组: 普通用户
  • 注册时间: 2007-01-19 14:41
文章分类

全部博文(330)

文章存档

2012年(17)

2011年(135)

2010年(85)

2009年(57)

2008年(36)

我的朋友

分类: C/C++

2010-06-07 20:08:43

转载自: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_AdapterActiveTimer,   ActiveTimer适配器允许你指定任何一种具体的定时器队列,充当主动定时器的底层定时器队列.
#include "ace/Time_Queue_Adapters.h"

#include "ace/Timer_Heap.h"
#include 
"ace/Timer_Wheel.h"
  //typedef ACE_Thread_Timer_Queue_AdapterActiveTimer,
#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, 
                            
const void *act /* = 0 */)
    
{
        ACE_TRACE(ACE_TEXT(
"CBB::handle_timeout "));
        ACE_DEBUG((LM_DEBUG, ACE_TEXT(
"Expiry handled by thread %t id=%d "),id_));
        
return 0;
    }

}
;
//要创建一个定时器回调处理器,在事件处理器上的handle_timeout方法被分派.

int Start()
{
    ACE_DEBUG((LM_DEBUG, ACE_TEXT(
"The main thread %t has started ")));

    ActiveTimer atimer;
    atimer.activate();

    CBB cb1(
1);
    CBB cb2(
2);
    
int arg1 = 1;
    
int arg2 = 2;
    
const ACE_Time_Value curr_tv = ACE_OS::gettimeofday();
    ACE_Time_Value interval 
= ACE_Time_Value(8,1000);
    ACE_Time_Value tv(
3);
    
long id1 = atimer.schedule(&cb1,&arg1,curr_tv+tv,interval);

    
/*ACE_Time_Value tvv(5);
    long id2 = atimer.schedule(&cb2,&arg2,curr_tv+tvv,interval);
*/


    ACE_Thread_Manager::instance()
->wait();


    
return 0;
}
阅读(2119) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~