ACE学习之定时器(Timer)
2010-05-14 17:43
330 查看
ACE
学习之定时器(Timer)
定时器(Timer)
在
事件超时的时候适当的调用事件处理器的handle_timeout()方法.为调度这样的定时器,反应器拥有一个schedule_timer()的方
法.该方法接受事件处理器,以及以ACE_Time_Value对象形式出现的延迟对味参数.此外,可以指定时间间隔,使定时器在它超时后自动恢复 .
反
应器在内部维护ACE_Timer_Queue,它以定时器要被调度的顺序对它们进行维护。实际使用的用于保存定时器的数据结构可以通过反应器的
set_timer_queue()方法进行改变。反应器有若干不同的定时器结构可用,包括定时器轮(timer wheel)、定时器堆(timer
heap)和哈希式定时器轮(hashed timer wheel)。
设置定时器:
Cpp代码
#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 ¤t_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适配器允许你指定任何一种具体的定时器队列,充当主动定时器的底层定时器队列.
Cpp代码
class
CBB :
public
ACE_Event_Handler
{
private
:
int
id_;
public
:
CBB(int
id) : id_(id){}
virtual
int
handle_timeout(
const
ACE_Time_Value ¤t_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;
}
学习之定时器(Timer)
定时器(Timer)
在
事件超时的时候适当的调用事件处理器的handle_timeout()方法.为调度这样的定时器,反应器拥有一个schedule_timer()的方
法.该方法接受事件处理器,以及以ACE_Time_Value对象形式出现的延迟对味参数.此外,可以指定时间间隔,使定时器在它超时后自动恢复 .
反
应器在内部维护ACE_Timer_Queue,它以定时器要被调度的顺序对它们进行维护。实际使用的用于保存定时器的数据结构可以通过反应器的
set_timer_queue()方法进行改变。反应器有若干不同的定时器结构可用,包括定时器轮(timer wheel)、定时器堆(timer
heap)和哈希式定时器轮(hashed timer wheel)。
设置定时器:
Cpp代码
#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 ¤t_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;
}
#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 ¤t_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适配器允许你指定任何一种具体的定时器队列,充当主动定时器的底层定时器队列.
Cpp代码
class
CBB :
public
ACE_Event_Handler
{
private
:
int
id_;
public
:
CBB(int
id) : id_(id){}
virtual
int
handle_timeout(
const
ACE_Time_Value ¤t_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;
}
相关文章推荐
- ACE学习之定时器(Timer)
- ACE学习之定时器(Timer)
- Java学习之道: java定时器的使用(Timer)
- 学习一下定时器timer+handler
- 【JavaSE学习笔记】多线程02_Lock,死锁,等待唤醒机制,线程组和线程池,Timer定时器
- 线程学习笔记(八)-定时器(Timer)
- ACE学习(九)ACE_Timer_Queue
- JAVA定时器 (Timer TimerTask)学习
- ACE_Timer_Heap_T定时器
- 并发学习之:等待定时器(Waitable Timer)
- java学习初探十八之线程的Timer定时器
- 并发学习之:等待定时器(Waitable Timer)
- C#多线程学习(五) 多线程的自动管理(定时器Timer)
- 【08】 Boost库学习笔记之定时器(Timer)
- muduo网络库学习(三)定时器TimerQueue的设计
- 【boost学习】之boost::asio(1)——Timer定时器
- ACE_Timer_Queue学习心得
- Android学习指南之三十四:Android定时器Timer的使用
- 《多线程编程》学习之十:定时器Timer的使用,线程安全的单例模式
- Timer,TimerTask 学习