该类主要服务于TimerId和TimerQueue这个两个类。
包含了超时时间,需要执行的函数,是否是周期性执行,周期时间。 还有一个是计时器序号
Timer
该类记录一个计时器,同时执行超时后的函数。
成员变量
- const TimerCallback _cb
该成员记录了,超时以后需要执行的函数。
其中
typedef boost::function<void()> TimerCallback;
- Timestamp _expiration
超时时间,微秒级别的。
因为使用的timerfd
也是个微秒级别的 - const bool _repeat
是否是个周期执行的函数
也就是说,开始执行以后,是否每隔多长时间就执行一次的函数 - const double _interval
周期时间 - const int64_t sequence
每个计时器的一个标志吧。每次的都不重复,每建立一个就+1
- static AtomicInt64 _s_numCreated;
这个是一个原子操作,用来给计数器标号的
成员函数
- 构造函数
构造函数需要记录超时时间,超时后执行的函数,周期时间。周期时间为0的话,那么就不周期执行
Timer(TimerCallback&& cb, Timestamp when, double interval)
: callback_(std::move(cb)),
expiration_(when),
interval_(interval),
repeat_(interval > 0.0),
sequence_(s_numCreated_.incrementAndGet())
{ }
- void run()
该函数会执行超时后执行的函数
void run()
{
_cd();
}
- 三个返回内部数据的函数
当计数器被调用以后,需要在来查询这些参数,判断是否再此将该计数器添加到时间队列中
Timestamp expiration() const { return _expiration; }
bool repeat() const { return _repeat; }
int64_t sequence() const { return _sequence; }
- void restart(Timestamp now);
重置超时时间
当计数器执行以后,需要判断该计数器是否是一个周期性计时器,如果是一个周期性计时器,那么需要重置该计时器的超时时间,然后再由其他函数将该计时器添加到时间队列中。‘
如果是一个周期性函数,那么需要将超时时间设定为当前时间+周期性执行时间(timerfd_create设置的是从时间纪元开始)
void restart(Timestamp now)
{
if (_repeat)
{
_expiration = addTime(now, _interval);
}
else
{
_expiration = Timestamp::invalid();
}
}
功能
该类,封装一个计时器。