time.AfterFunc 不支持优先级延迟队列，因其仅为单次定时器，无堆结构、不可动态调整或取消任务；需用 container/heap 实现最小堆，按到期时间与优先级两级排序，并用单个 timer 轮询驱动。
为什么不能直接用 time.AfterFunc 做优先级延迟队列
time.AfterFunc 只支持单一时间点触发，无法动态调整任务执行顺序，也不能按优先级插入或取消待执行任务。它背后是单个定时器 + goroutine，没有任务索引、无堆结构、不支持 O(log n) 插入/删除 —— 本质上是个“一次性倒计时闹钟”，不是队列。
真正需要的是：任务可按 到期时间 + 优先级 两级排序；支持随时插入新任务；能高效取出下一个该执行的任务；最好还能取消已入队但未触发的任务。
- 典型场景：消息重试（高优订单消息比低优日志消息更早重试）、定时调度（同一秒内多个任务需按优先级先后执行）
- 关键约束：插入/取最小任务必须是 O(log n)，否则高频写入下性能崩塌
- 常见误操作：用
sort.Slice每次插入后全量重排 → O(n log n)，1000 任务插入 100 次就卡住
用 container/heap 实现带优先级的最小堆任务节点
Go 标准库的 container/heap 要求你实现 heap.Interface，核心是定义三个方法：Len、Less、Swap，再加 Push 和 Pop（注意：这两个不是接口方法，而是你要自己写的函数）。
任务结构体要包含：dueTime time.Time（绝对触发时间）、priority int（数值越小优先级越高）、task func()、以及一个 id int64（用于后续取消）。
立即学习“go语言免费学习笔记（深入）”；
Less(i, j int) bool 必须先比 dueTime，时间相等时再比 priority：
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
func (pq PriorityQueue) Less(i, j int) bool {
if pq[i].dueTime.Equal(pq[j].dueTime) {
return pq[i].priority < pq[j].priority // 同一时刻，优先级数字小的先执行
}
return pq[i].dueTime.Before(pq[j].dueTime)
}
- 别用
UnixNano()直接比整数 ——time.Time自带Before/Equal更安全，避免时区/纳秒溢出问题 - 别在
Less里调用time.Now()—— 堆比较是纯逻辑，不该有副作用 -
Push和Pop必须用指针接收者，否则heap.Push修改不了底层数组
如何安全取消已入队但未执行的任务
标准 heap 不支持按值删除，所以得靠“懒删除”+“标记位”。给每个任务加一个 removed bool 字段，在 Pop 时跳过已标记的节点。
取消逻辑不是从堆中物理移除，而是：查到目标 id → 设 removed = true → 后续 Pop 遇到就丢弃。需要额外维护一个 map[int64]*Task 来快速定位任务指针。
- 这个 map 必须加
sync.RWMutex，因为插入、取消、Pop 三处并发读写 - Pop 循环里不能只做一次检查：要
for pq.Len() > 0 { t := heap.Pop(&pq).(*Task); if !t.removed { return t } } - 别忘了在
Push时把新任务存进 map，Pop返回前从 map 删除（或留着等 GC）
驱动执行器：用单个 time.Timer 轮询最小堆，而非为每个任务启 timer
为每个任务起一个 time.Timer 是灾难性的：10 万任务 = 10 万个系统 timer，内存和调度开销爆炸。正确做法是只维护一个 timer，每次从堆顶取最近任务，设置其 dueTime.Sub(time.Now()) 作为等待时长。
当 timer 触发，执行任务后，立刻重新从堆里取下一个任务（如果还有），重设 timer。若堆空了，就什么也不做。
- 必须用
timer.Reset(d)而非新建 timer —— 避免 timer 泄漏 - Reset 前要先
Stop()，否则可能 panic：“timer already fired” - 时间差可能为负（任务已超时），此时应立即执行，而不是传负数给 Reset
- 整个执行循环要包在
select { case 里，支持优雅退出
最易被忽略的一点：堆顶任务的 dueTime 在入队后可能被外部修改（比如用户想延后执行），但堆结构不会自动重排。这种需求必须显式调用 heap.Fix(&pq, idx)，而你需要提前保存每个任务在堆中的索引 —— 这会让代码复杂度陡增。生产环境建议禁止运行时修改 dueTime，只允许插入新任务 + 取消旧任务。
