golang调度怎么调

在Go语言里聊“任务调度”，很容易踩进一个误区——把time.Ticker和time.AfterFunc当成调度器。严格来说，它们只是定时信号的触发器，跟真正的任务调度不是一回事。Golang的GMP模型管的是goroutine在多少个OS线程上跑，它不做业务层面的优先级排序，也不管哪个任务该先执行。所以，如果你需要的是“任务调度”，那就得自己动手造轮子。

用container/heap做优先级队列，别自己手写排序

标准库里没有现成的优先级队列，这倒不算坏事。container/heap是官方提供的一个轻量级选择，可控性很好。千万别用sort.Slice或者切片插入再重排——每次增删都是O(n log n)，而且一旦任务多了，根本无法动态调整执行时间。

这里有几个值得留意的细节：

• Less(i, j int) bool这个方法里，必须先比较Priority（数值越小优先级越高），再比较CreatedAt或ExecTime。如果不这么做，同优先级的任务很可能被饿死。
• 每次执行heap.Push或heap.Pop之后，记得调用heap.Fix(pq, i)或heap.Init(pq)。堆结构一旦失效，下一次Pop取出的可能根本不是你要的任务。
• 别在Less方法里查数据库、加锁或调API。这个方法被调用的频率非常高，一旦阻塞，整个调度循环都会卡住。

time.Timer配合队列做动态重调度，不是简单地用Reset

想要实现任务插队、取消、延迟重试，不能靠反复time.AfterFunc递归，也别直接用time.NewTimer然后随意Reset。正确的做法是：全局只有一个*time.Timer，它永远指向队列里最近需要执行的那个任务。

具体操作上：

• 调用Timer.Reset之前，必须先做if !t.Stop() { }检查。否则旧的timer可能在后台继续发信号，导致panic，比如send on closed channel或invalid memory address。
• 任务入队、出队或优先级发生变化后，立刻重新计算堆顶的ExecTime，然后Reset全局timer。如果堆空了，就别调用Reset了，Stop是安全的。
• timer触发时，不要让业务函数直接在触发逻辑里执行——用goroutine异步跑，避免阻塞调度主循环。同时要检查当前任务是否已经被取消，比如通过task.Status == Canceled来判断。

worker pool必须带recover、context和限流

每个任务都直接起goroutine可不是好习惯。一次panic就能让整个进程崩溃；不设超时的话，一个慢任务就能把全部worker拖垮。

几个关键点：

• worker数量别硬编码。I/O密集型场景建议设为runtime.NumCPU() * 3，CPU密集型就用runtime.NumCPU()。
• 每个worker内部必须包一层defer func() { recover() }()，否则任意handler panic都会导致worker退出，任务就会在队列里越积越多。
• 任务执行前，用ctx, cancel := context.WithTimeout(parentCtx, task.Timeout)创建上下文，执行完后立刻调用cancel()。别依赖HTTP层的超时设置——它管不到你自己的goroutine。
• 用golang.org/x/sync/semaphore来控制并发上限，比无缓冲channel更易观测和调试。

别碰runtime.GOMAXPROCS，除非你在容器里跑满核

默认值通常就是最优解——等于CPU核心数。强行设小，goroutine会排队；设大，线程切换的开销反而上升。真正影响吞吐量的是任务结构和worker的设计，不是P的数量。

有几个例外情况需要注意：

• GOMAXPROCS的调整只对CPU密集型程序有意义，而绝大多数后台任务其实是I/O密集型的。
• 在容器环境（比如Kubernetes）里，如果限制了CPU limit，runtime.NumCPU()返回的值可能不准确。这时应该读取/sys/fs/cgroup/cpu/cpu.cfs_quota_us和/sys/fs/cgroup/cpu/cpu.cfs_period_us来手动计算可用核数。
• 修改GOMAXPROCS后不重启服务，新设置不会生效。runtime包本身不提供reload接口，所以千万别在运行时反复调runtime.GOMAXPROCS()。

说到底，难点不在于怎么建堆，而在于怎么管理状态。任务执行失败后要不要进重试队列？重试次数用完了要不要触发告警？所有这些逻辑，都得在Handler执行完毕之后、worker循环继续之前，同步更新到持久化存储或消息队列里。否则进程一挂，所有的任务状态就全丢了。