《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任务。