《Ceph源码分析》——第2章，第6节SafeTimer

本节书摘来自华章出版社《Ceph源码分析》一书中的第2章，第2.6节SafeTimer，作者常涛，更多章节内容可以访问云栖社区“华章计算机”公众号查看

2.6　SafeTimer
类SafeTimer实现了定时器的功能，代码如下：

class SafeTimer
{
  CephContext *cct;
  Mutex& lock;
  Cond cond;
  bool safe_callbacks;      //是否是safe_callbacks

  SafeTimerThread *thread;  //定时器执行线程

  std::multimap<utime_t, Context*> schedule;
                            //目标时间和定时任务执行函数Context
  std::map<Context*, std::multimap<utime_t, Context*>::iterator> events;
                            //定时任务<-->定时任务在shedule中的位置映射
  bool stopping;            //是否停止
}

添加定时任务的命令如下：
void SafeTimer::add_event_at(utime_t when, Context *callback)
取消定时任务的命令如下：
bool cancel_event(Context *callback);
定时任务的执行如下：
void SafeTimer::timer_thread()
本函数一次检查scheduler中的任务是否到期，其循环检查任务是否到期执行。任务在schedule中是按照时间升序排列的。首先检查，如果第一任务没有到时间，后面的任务就不用检查了，直接终止循环。如果第一任务到了定时时间，就调用callback函数执行，如果是safe_callbacks，就必须在获取lock的情况下执行Callback任务。