Go time.AfterFunc 回调和主 goroutine 如何安全协作

time.AfterFunc 最容易被误用的地方，是把它当成“在当前 goroutine 里稍后执行”。实际上，回调会在独立 goroutine 中运行。安全的协作方式是：回调只发送一个事件，不直接改主 goroutine 的业务变量；主 goroutine 收到事件后再更新状态。停止定时器时，还要区分“尚未启动”和“已经启动但尚未结束”。

先把 AfterFunc 的三个边界分清楚

time.AfterFunc(d, f) 到期后会调用 f，但调用位置是新的 goroutine；它返回的 Timer.C 为 nil，不能像 NewTimer 那样接收时间值。Stop 返回 true，表示这次调用阻止了回调启动；返回 false，表示定时器已经到期或此前已停止，回调可能正在运行。

因此，下面这种写法有数据竞争风险：

var timedOut bool

time.AfterFunc(200*time.Millisecond, func() {
    timedOut = true // 回调 goroutine 写入
})

if timedOut { // 主 goroutine 同时读取
    // 这里没有同步关系
}

即便短时间内“看起来能工作”，也不能把调度时序当作同步机制。需要验证时，用 go test -race 或 go run -race 覆盖这条路径；竞态检测器只能报告实际运行到的冲突，所以触发和取消都应该有测试。

用事件通道把状态写入权交还给主 goroutine

下面的模式适合“一次定时提醒、主流程还在等待”的场景。回调不携带可变状态，只发送一个常量事件；事件通道容量为 1，避免主流程已经离开接收分支时回调被无意义地卡住。

package main

import (
    "fmt"
    "time"
)

type event string

const timeout event = "timeout"

func main() {
    events := make(chan event, 1) // 回调只投递事件，不共享业务变量
    stop := make(chan struct{})   // 通知回调放弃投递
    callbackDone := make(chan struct{})

    timer := time.AfterFunc(200*time.Millisecond, func() {
        defer close(callbackDone) // 明确标记回调已经返回
        select {
        case events 

这里有两个不同职责的通道：stop 解决“回调还要不要投递”，callbackDone 解决“回调是否已经返回”。不要用一个布尔值替代它们，也不要在主 goroutine 关闭 events；发送方仍可能在回调中执行，关闭接收方维护的业务通道会制造新的竞态或 panic。

Stop 返回 false 时，为什么还要等待 callbackDone

Stop() 不是 join 操作。它返回 false 时，回调可能已经把事件发送出去，也可能正停在 select 中，甚至刚准备执行。先关闭 stop，再等待 callbackDone，才能保证回调不会在函数返回后继续使用即将释放的资源。

在真实服务里，回调若还需要调用外部资源，可以把资源访问放进回调的生命周期内，并把释放动作放在等待之后。例如数据库连接、文件句柄、请求上下文相关对象，都不能因为 Stop 返回就立即假设无人使用。

Reset 不能替代并发协调

如果回调已经过期或停止，Reset 返回 false，并会安排新的回调；它不会等待上一次回调完成，也不保证两次回调不并发。需要重复调度时，建议把“是否允许下一次执行”放在单独的调度 goroutine 中，或让每次回调都通过同一个事件通道进入主循环。不要在多个 goroutine 中随意调用 Reset，再靠返回值推断业务顺序。

可以按下面的检查清单做一次代码复查：

相关问题

AfterFunc 的回调能不能直接调用主 goroutine 的函数？

可以调用普通函数，但函数内部不能未经同步地读写主 goroutine 维护的共享状态。更稳妥的方式是发送事件，由主循环调用业务函数。

Stop 返回 true 后还需要等 callbackDone 吗？

对同一个尚未启动的回调，不需要；返回 true 表示这次 Stop 阻止了它启动。若代码还有其他执行路径，仍要保证完成通道的关闭协议只执行一次。

什么时候应该改用 NewTimer？

如果业务天然是“主循环等待一个时间值”，优先用 NewTimer 的 C 通道；只有确实需要到期后执行函数时才用 AfterFunc，并为停止和完成设计协议。

参考：Go time.AfterFunc 文档、Timer.Stop 文档、Go Data Race Detector。