std::priority_queue默认是最大堆,因使用std::less比较器,故定时器需显式指定std::greater或自定义仿函数实现最小堆,确保最早到期任务位于堆顶。

为什么 std::priority_queue 默认不是最小堆
因为 std::priority_queue 默认用 std::less 作为比较器,底层是最大堆——顶部元素是最大值。定时器需要最快到期的(即最小到期时间)排在队首,所以必须改成最小堆。
常见错误是直接写 std::priority_queue,结果 top() 返回最晚触发的任务,导致定时器逻辑完全颠倒。
正确做法是显式传入 std::greater,前提是 T 支持 operator>,或者自定义比较仿函数:
struct TimerTask {
long long expire_at; // 毫秒时间戳
std::function<void> cb;
bool operator>(const TimerTask& rhs) const { return expire_at > rhs.expire_at; }
};
// 方式1:用 std::greater(需定义 operator>)
std::priority_queue<timertask std::vector>, std::greater<timertask>> heap;
// 方式2:用 lambda(C++20 起支持,但注意不能直接用于模板参数,需用 struct 包装)
// 更稳妥:用自定义仿函数对象
struct EarlierExpire {
bool operator()(const TimerTask& a, const TimerTask& b) {
return a.expire_at > b.expire_at; // 注意:这是“a 应该排在 b 后面”的逻辑,即小顶堆
}
};
std::priority_queue<timertask std::vector>, EarlierExpire> heap;
</timertask></timertask></timertask></void>
如何安全地从堆中取出已到期任务
定时器主线程(或 IO 线程)需循环检查堆顶是否到期,但必须注意:不能只 top() 一次就跳出,因为可能多个任务在同一时刻到期;也不能无限制 pop() 直到堆空——得用当前系统时间做边界判断。
典型误操作是:
- 用
while (!heap.empty() && heap.top().expire_at 却忘了在循环内pop(),导致死循环 - 在回调执行过程中又往堆里插入新任务,而此时正在
pop(),虽不导致崩溃,但新任务不会被本轮处理
推荐结构:
auto now = GetMonotonicMillis(); // 务必用单调时钟,不用 system_clock while (!heap.empty() && heap.top().expire_at <p>注意:<code>task.cb()</code> 是用户代码,可能抛异常、阻塞、甚至递归调用 <code>add_timer()</code> —— 这本身没问题,只要确保堆操作(<code>push</code>/<code>pop</code>)是线程安全的(见下一点)。</p><h3>多线程环境下 push/pop 的线程安全怎么做</h3><p><code>std::priority_queue</code> 本身不是线程安全容器。如果一个线程在 <code>push()</code>,另一个在 <code>pop()</code> 或 <code>top()</code>,会引发未定义行为(常见表现是崩溃或数据错乱)。</p><div class="aritcle_card flexRow artxards"> <div class="artcardd flexRow"> <a class="aritcle_card_img" rel="nofollow" href="/xiazai/gongju/2823" title="C++14"><img src="https://img.php.cn/upload/manual/001/431/639/6ac8b33c327c4749.png" alt="C++14" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a> <div class="aritcle_card_info flexColumn"> <a rel="nofollow" href="/xiazai/gongju/2823" title="C++14" class="overflowclass">C++14</a> <p class="overflowclass">C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。</p> </div> <a rel="nofollow" href="/xiazai/gongju/2823" title="C++14" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a> </div> </div><p>不能靠“我只在单个线程里操作”来假设安全——定时器通常有两类线程:工作线程调用 <code>add_timer()</code>,而定时器驱动线程(比如 epoll/kqueue 循环或独立 timer thread)负责到期检查和回调。</p><p>简单有效的方案是加互斥锁,但要注意粒度:</p>
- 不要把整个事件循环锁住(比如把
while(!heap.empty() && ...)整个包进 lock)——会严重拖慢定时器响应 - 只锁必要的临界区:
push()、top()、pop()这三个操作各自包裹std::lock_guard - 回调
task.cb()必须在锁外执行,否则用户代码阻塞会导致其他线程长期等待
示例:
std::mutex heap_mtx;
// add_timer:
{
std::lock_guard<:mutex> lk(heap_mtx);
heap.push(std::move(task));
}
// tick loop:
while (true) {
auto now = GetMonotonicMillis();
std::vector<timertask> expired;
{
std::lock_guard<:mutex> lk(heap_mtx);
while (!heap.empty() && heap.top().expire_at <h3>为什么不能用 <code>std::chrono::time_point</code> 直接当堆元素</h3>
<p>有人尝试用 <code>std::pair<:chrono::steady_clock::time_point std::function>></:chrono::steady_clock::time_point></code> 做堆元素,认为 <code>time_point</code> 已支持 <code>,省得自己写比较逻辑。但问题在于:<code>time_point</code> 的 <code>operator 虽可用,但它在 <code>std::priority_queue</code> 中仍会构建最大堆,除非你主动指定 <code>std::greater<...></...></code>。</code></code></p>
<p>更隐蔽的问题是精度与可比性:不同 clock 的 <code>time_point</code> 类型不同(<code>system_clock::time_point</code> 和 <code>steady_clock::time_point</code> 不可混用),且 <code>time_point</code> 无法直接序列化/调试打印,出问题时难排查。</p>
<p>建议统一转为整数时间戳(如毫秒级 <code>long long</code>),好处是:</p>
<ul>
<li>比较开销小(整数比 <code>time_point</code> 构造/转换快)</li>
<li>跨平台一致(避免 Windows/Linux 下 <code>steady_clock</code> 分辨率差异)</li>
<li>便于日志记录和调试(直接 <code>std::cout )</code>
</li>
</ul>
<p>获取方式务必用单调时钟:</p>
<pre class="brush:php;toolbar:false;">
// 推荐:使用 steady_clock + duration_cast
inline long long GetMonotonicMillis() {
return std::chrono::duration_cast<:chrono::milliseconds>(
std::chrono::steady_clock::now().time_since_epoch()).count();
}
</:chrono::milliseconds>
实际最难处理的不是堆本身,而是时间跳变(NTP 校正、手动改系统时间)和回调重入——这些必须在上层业务逻辑里防御,std::priority_queue 只负责按序交付。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!










