Go语言实现简单的时间轮算法：语言学习中的高效定时器-Golang-PHP中文网

time.timer不适合高频大批量定时任务，因其底层小顶堆导致reset/stop时间复杂度为o(log n)，引发gc压力与调度开销；时间轮以o(1)摊还复杂度、固定数组+槽位分桶设计更适配高频低延迟场景。

go语言实现简单的时间轮算法：语言学习中的高效定时器

为什么 `time.Timer` 不适合高频、大批量定时任务

Go 标准库的 time.Timer 底层基于四叉堆（实际是小顶堆），每次 Reset() 或 Stop() 都涉及堆调整，时间复杂度 O(log n)。当每秒创建/重置成千上万个定时器时，GC 压力和调度开销会明显上升——这不是 bug，而是设计取向：它面向的是“少量、长周期、高精度”场景。

时间轮（Timing Wheel）换了一种思路：用固定大小数组 + 槽位分桶，把插入/删除摊还到 O(1)。适合 IoT 心跳、连接空闲超时、批量任务延迟触发等典型高频低延迟需求。

单层时间轮适用于总时间跨度可控（比如 0–60s，精度 100ms）
多层时间轮（如 Kafka 的层级设计）才能覆盖小时/天级，但实现复杂度陡增
Go 中无需锁的常见做法是每个槽位配一个 sync.Pool 复用节点，避免频繁分配

手写单层时间轮的关键结构与初始化

核心是三个东西：槽位数组、当前 tick 指针、推进 tick 的 goroutine。不要用 map[int][]*Timer，直接用 slice 更快更省内存。

Go语言（Golang）1.26.0

Go语言（Golang）1.26.0版本提供 Go 官方 Windows amd64 MSI 安装包下载入口，版本号 1.26.0，可用于旧项目维护、兼容性测试和指定版本开发环境配置。

下载

type TimingWheel struct {
    slots    []*list.List // 每个槽位存一个双向链表
    interval time.Duration
    ticks    uint32
    ticker   *time.Ticker
}
<p>func NewTimingWheel(interval time.Duration, slotCount int) <em>TimingWheel {
tw := &TimingWheel{
slots:    make([]</em>list.List, slotCount),
interval: interval,
ticker:   time.NewTicker(interval),
}
for i := range tw.slots {
tw.slots[i] = list.New()
}
return tw
}</p>

interval 决定最小时间粒度，设太小（如 1ms）会导致 ticker 频繁唤醒，设太大（如 1s）则误差不可控
slotCount 决定最大延时：最大支持延时 = interval * slotCount，超出需拒绝或降级处理
别在 tick goroutine 里做耗时操作（如网络调用），否则会拖慢整个轮子推进节奏

`AddTimer()` 怎么算槽位索引并安全插入

关键不是哈希，而是取模：延时时间 ÷ 精度 → 得到相对 tick 数 → 对槽数取模 → 定位槽位。注意负数和溢出。

func (tw *TimingWheel) AddTimer(d time.Duration, f func()) *Timer {
    delayTicks := uint32(d / tw.interval)
    if delayTicks >= uint32(len(tw.slots)) {
        // 超出范围，可 panic 或返回 error，视业务容忍度而定
        return nil
    }
    slotIdx := (tw.ticks + delayTicks) % uint32(len(tw.slots))
    t := &Timer{callback: f}
    tw.slots[slotIdx].PushBack(t)
    return t
}

必须用 uint32 避免负数取模行为不一致（Go 中负数 % 正数结果为负）
不要在插入时启动 goroutine 执行回调——等 tick 到达再统一执行，否则并发控制变复杂
如果要求“取消定时器”，得给 Timer 加字段记录所属槽位和 list.Element，否则无法从链表中删

tick 推进时如何清理已到期定时器

每次 ticker.C 触发，先移动 ticks，再遍历当前槽位所有节点，逐个执行回调。重点是：执行前要从链表中移除节点，防止重复触发；且不能阻塞 tick 主线程。

go func() {
    for range tw.ticker.C {
        idx := tw.ticks % uint32(len(tw.slots))
        for e := tw.slots[idx].Front(); e != nil; {
            next := e.Next()
            t := e.Value.(*Timer)
            tw.slots[idx].Remove(e)
            go t.callback() // 异步执行，避免阻塞
            e = next
        }
        tw.ticks++
    }
}()