带优先级的时间轮定时器通过三级分层时间轮、优先级有序链表、跨轮归一化、无锁tick驱动和动态优先级调整实现高并发精准调度。

如果您需要在高并发场景下精确、低开销地调度大量定时任务,且要求不同任务具有差异化执行优先级,则传统 std::chrono + 线程轮询或单层时间轮无法兼顾效率与优先级语义。以下是实现带优先级的时间轮定时器的核心步骤:
一、分层多精度时间轮结构设计
采用三级时间轮结构:毫秒轮(64槽,覆盖0–63ms)、秒轮(64槽,覆盖0–63s)、分钟轮(64槽,覆盖0–63min),各轮独立运行并逐级溢出。优先级嵌入槽位链表节点,使同一槽内任务按 priority 值升序插入,保证高优先级任务先被取出执行。
1、定义时间轮槽位节点结构体,包含 task 函数对象、触发时间戳、priority 整型字段及 next 指针。
2、为每个时间轮分配固定大小的 std::vector,索引按当前精度取模计算,例如毫秒轮使用 now_ms % 64 作为槽位索引。
3、插入新定时任务时,根据其绝对触发时间戳计算归属轮次与槽位,再按 priority 值在对应槽位链表中执行有序插入。
二、优先级感知的槽位遍历与执行
每次 tick 触发时,仅扫描当前激活槽位内的链表,但遍历顺序不按插入顺序,而是严格依据 priority 升序——即 priority 值越小,执行优先级越高。该策略避免全局堆排序开销,将优先级决策下沉至局部链表维护。
1、在毫秒轮当前槽位链表头部设置临时指针,沿 next 链顺序访问节点。
2、对每个节点检查其 priority 字段,若小于当前已执行任务的最小 priority,则将其前置到待执行队列首部。
3、收集完本槽全部节点后,按 priority 升序批量调用 task(),执行完毕后立即从链表中移除。
三、跨轮溢出与时间戳归一化处理
当毫秒轮完成一轮(64次 tick)后,需将溢出任务迁移至秒轮对应槽位;同理,秒轮满64次后迁移至分钟轮。迁移过程中必须重写节点中的绝对时间戳,并重新按目标轮精度进行 priority 加权归一化,确保跨轮后优先级语义不漂移。
1、在毫秒轮 tick 达到64时,触发 overflow_to_second(),遍历所有毫秒轮槽位链表,提取剩余未触发任务。
2、对每个任务节点,将其原触发时间戳减去当前毫秒轮起始时间,得到相对偏移,再除以1000获得秒级偏移,取模64得秒轮槽位索引。
3、将节点插入秒轮对应槽位前,将其 priority 字段右移2位(等效乘以0.25),防止低精度轮次任务长期压制高精度轮次新任务。
四、无锁环形缓冲区驱动 tick 推进
tick 信号不由系统时钟直接触发,而是由生产者线程通过无锁环形缓冲区(如 boost::lockfree::spsc_queue)推送时间增量事件。消费者线程持续读取增量并累加本地逻辑时钟,驱动三级轮盘旋转。该设计消除系统调用阻塞,避免时钟抖动干扰优先级响应延迟。
1、初始化一个容量为1024的单生产单消费无锁队列,用于传输 uint64_t 类型的毫秒增量。
2、网络I/O线程在每次 epoll_wait 返回后,计算本次就绪事件处理耗时,将该值封装为增量事件 push 入队。
3、定时器主循环线程持续 pop 增量并更新本地 clock_ms,每累加1ms即推进毫秒轮指针1格,必要时触发溢出逻辑。
五、任务句柄与动态优先级调整接口
每个注册任务返回唯一 handle(uint64_t 类型),该 handle 实际为指向节点内存地址的哈希编码,支持 O(1) 定位。通过 handle 可在任务触发前修改其 priority 字段,从而实现运行时优先级升降,无需取消重设。
1、注册任务时,分配堆内存节点,构造完成后将地址经 std::hash
2、提供 adjust_priority(handle, new_priority) 接口,通过 handle 还原原始指针,直接写入 new_priority 值。
3、在下一次 tick 扫描该节点所在槽位时,其新的 priority 值将参与本轮链表内重排序与执行顺序判定。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











