sync.pool 不能实现带优先级和过期的任务池，因其仅用于临时对象复用，不支持调度、优先级排序或ttl控制；应使用 container/heap 构建优先级队列，任务结构体需含 expireat 和 priority 字段，less 方法先按过期时间升序，再按优先级升序比较。
为什么不能直接用 sync.Pool 实现带优先级和过期的任务池
sync.Pool 是为临时对象复用设计的，不支持任务调度逻辑，也没有优先级队列或 TTL 控制能力。它既不保存任务状态，也不提供执行时机控制——你往里放一个 func()，它不会帮你运行，更不会按优先级或剩余时间排序。真要用它来“池化任务”，反而会绕进资源泄漏和竞态的坑里。
用 container/heap 构建可排序的优先级队列
Go 标准库没提供开箱即用的优先级队列，但 container/heap 可以低成本实现：关键不是堆本身，而是定义好 Less 方法的比较逻辑。任务结构体需同时携带优先级和过期时间，Less 应优先比过期时间（早过期的先执行），时间相同时再比优先级（数值越小优先级越高，或按业务约定）。
- 定义任务结构体时，把
expireAt设为time.Time，避免整数时间戳带来的时区/精度歧义 - 实现
heap.Interface时，Less(i, j int)先判断t[i].expireAt.Before(t[j].expireAt)，相等再比t[i].Priority - 每次
Push或Pop后必须手动调用heap.Fix或heap.Init，否则排序失效
如何安全地从队列中取出待执行任务
取任务不是简单 Pop 最顶元素，得先检查是否已过期、是否被取消。典型错误是只按堆顶取，却忽略中间节点可能已过期——因为堆只保证根最小，其余无序。正确做法是循环 Peek + 条件 Pop，直到拿到一个未过期且未取消的任务，或队列为空。
- 用
time.Now().After(task.expireAt)判断过期，别用time.Since防止负值干扰 - 任务结构体加
done字段（sync.Once或atomic.Bool），在执行前CompareAndSwap标记，避免重复执行 - 不要在
Pop后才检查过期——此时任务已出队，若丢弃就丢失调度语义；应在Pop前通过索引访问堆顶并验证
启动工作协程时怎么避免 goroutine 泄漏
常见写法是起一个无限 for 循环不断 Pop 执行，但没退出机制：当任务池被关闭或长期无任务时，goroutine 会永远阻塞在空队列上。必须配合 context.Context 和带超时的等待逻辑。
- 用
time.AfterFunc或time.NewTimer替代time.Sleep，便于在关闭时Stop()防止泄漏 - 每次取任务前，先
select等待ctx.Done()，再select等待任务就绪（可用timer.C触发重试） - 关闭池时，要先关闭所有 pending task 的
done信号，再close通知 channel，最后WaitGroup.Wait()等待正在执行的任务结束
优先级和过期时间不是叠加特性，而是调度策略的两个约束维度；处理不好，一个维度的优化（比如只按优先级排）会让另一个（比如过期控制）完全失效。真正难的不是堆怎么写，是每次取任务时那几行 select 和 atomic 的组合逻辑。
