时间轮通过空间换时间策略优化高并发定时任务调度。核心方法包括:一、单层时间轮+哈希桶;二、分层时间轮;三、无锁环形缓冲区+时间戳预排序;四、内存池化+对象复用。

如果您在高并发场景下需要精确、低开销地管理大量定时任务,则传统基于红黑树或最小堆的定时器可能面临插入/删除时间复杂度高、内存碎片多、缓存不友好等问题。时间轮(Timing Wheel)通过空间换时间策略,将定时任务按时间槽均匀分布,显著降低单次操作平均耗时。以下是实现高性能时间轮任务调度器的多种核心方法:
一、单层时间轮 + 哈希桶优化
适用于时间跨度有限、任务超时值相对集中的场景。将时间轴划分为固定数量的时间槽(slot),每个槽维护一个任务链表;使用哈希桶替代链表头指针数组,减少伪共享并提升CPU缓存命中率。
1、定义时间槽大小为 64,总槽数为 2048,底层采用 std::array<:atomic>, 2048> 存储每个槽的头节点指针。
2、任务插入时,根据到期时间戳计算槽索引:slot_index = (expire_time / tick_ms) & 2047,再通过原子CAS将新节点插入对应槽的链表头部。
立即学习“C++免费学习笔记(深入)”;
3、每 tick_ms 触发一次 tick 操作,使用 std::atomic
4、执行完毕后,将该槽头指针原子置空,避免重复调度;所有节点内存由对象池统一回收,禁止直接 delete。
二、分层时间轮(Hierarchical Timing Wheel)
解决单层时间轮时间跨度受限问题。采用多级结构:第一级为毫秒级细粒度轮(如 256 槽 × 1ms),溢出任务降级至第二级(如 64 槽 × 256ms),依此类推。各级轮独立推进,仅在低位轮绕回时触发高位轮单步前进。
1、构建五级时间轮:L0(256×1ms)、L1(64×256ms)、L2(64×16s)、L3(64×17m)、L4(64×18h),各级均使用 std::vector<:list>> 实现槽存储。
2、插入任务时,从 L0 开始尝试放置;若超出本级最大覆盖时间,则逐级向上计算应归属层级与槽位,最终落于对应槽中。
3、tick 推进由高精度 std::chrono::steady_clock::now() 驱动,每次只推进 L0 一格;L0 绕回时,原子递增 L1 当前指针;L1 绕回则递增 L2,以此类推。
4、每级轮扫描仅遍历当前指针指向的单个槽,取出全部任务句柄,通过无锁队列投递给工作线程池执行回调,确保调度主线程零阻塞。
三、无锁环形缓冲区 + 时间戳预排序
规避多线程环境下锁竞争,将任务插入与调度解耦。使用两个无锁环形缓冲区:一个用于生产者(用户线程)批量提交待调度任务,另一个用于消费者(调度线程)按时间戳顺序归并写入时间轮槽位。
1、定义大小为 8192 的 MoCircBuffer
2、用户调用 schedule() 时,将任务写入生产缓冲区;调度线程每 0.5ms 轮询一次,批量取出所有就绪任务,按 (expire_time % wheel_period) 分配到对应槽位数组的临时缓冲区。
3、对每个槽位的临时缓冲区调用 std::sort() 按 expire_time 升序排列,再以尾插方式合并入该槽的 lock-free intrusive list。
4、调度线程在推进槽指针前,先完成所有槽位的归并排序与链表合并,避免任何临界区加锁且保持任务执行顺序严格按超时时间先后。
四、内存池化 + 对象复用机制
防止高频任务创建/销毁引发堆分配抖动与内存碎片。所有 TaskNode、TimerHandle、CallbackWrapper 对象均从预分配的线程局部内存池中获取,生命周期由引用计数与 epoch-based 回收协同管理。
1、初始化阶段为每个 CPU 核心预分配 4MB 内存页,划分为 128 字节对齐的固定大小块,使用 bitmap 管理空闲状态。
2、TaskNode 构造时不调用 new,而是从当前线程绑定的内存池中申请;析构时不释放,仅将节点标记为可重用并加入本地空闲链表。
3、当本地空闲链表长度超过阈值时,触发批量归还至全局池;全局池采用 epoch barrier 机制,在确认无任何线程正在访问某批内存后,才允许其被覆盖复用。
4、所有回调函数对象通过 small functor 优化:sizeof 消除额外堆分配与虚函数调用开销。
五、SIMD 加速槽位扫描与批量触发
在 x86-64 平台利用 AVX2 指令集并行比较多个槽位的到期时间戳,一次性识别出所有需触发的任务批次,大幅提升单位周期内处理吞吐量。
1、将每个槽的最早任务时间戳(uint64_t)连续存放于 32 字节对齐的数组中,每 4 个槽组成一组,共 8 组映射到 256 位寄存器。
2、调度线程每 tick 执行一次 _mm256_load_si256 加载当前轮所有槽首节点时间戳,与当前时间做 _mm256_cmpgt_epi64 比较。
3、使用 _mm256_movemask_epi8 提取比较结果掩码,通过查表法快速定位哪些槽存在到期任务,跳过全空或未到期槽。
4、对命中槽位,调用 _mm256_i64gather_epi64 批量加载对应链表头指针,交由多路工作线程并发执行;单次 SIMD 扫描可覆盖 32 个槽位,吞吐提升达 4.2 倍。



















