定时器竞态

使用 time.AfterFunc 时，最容易误解的是把 Timer.Stop 当成“等待回调结束”。实际上，AfterFunc 会在自己的 goroutine 中调用回调；Stop() 返回 false 时，只能说明定时器已经到期或已经停止，不能说明回调已经执行完。只要取消动作和到期时刻可能同时发生，就必须把“阻止启动”和“等待收尾”分开处理。

判断规则很简单：Stop() == true 表示回调还没有启动并且被成功阻止；Stop() == false 表示不能再取消，回调可能已经启动。若调用方要释放回调使用的资源，就要额外等待一个完成信号。

AfterFunc 到底在哪里执行回调

time.AfterFunc(d, f) 创建的是函数型定时器。等待时长结束后，Go 会在独立 goroutine 中调用 f，返回的 *time.Timer 只用于控制这个调用。它的 C 字段不用于接收通知，因此不能用读取 timer.C 的方式等待回调。

下面的写法可以展示生命周期，但最后的 Stop 只负责尝试取消，不能替代回调内部的完成同步：

package main

import (
	"fmt"
	"time"
)

func main() {
	timer := time.AfterFunc(200*time.Millisecond, func() {
		// 回调由独立 goroutine 执行；这里的工作可能与 Stop 并发。
		fmt.Println("callback running")
	})

	if timer.Stop() {
		// true 表示回调尚未启动，本次调用已被阻止。
		fmt.Println("callback cancelled")
		return
	}

	// false 只表示不能再取消，不代表回调已经执行完。
	fmt.Println("callback may be running")
}

Stop 返回值应该怎样解释

对 AfterFunc 返回的函数型定时器，Stop 有两个关键信息：

竞态发生在两个动作靠近时：计时器线程准备启动回调，取消方同时调用 Stop。如果 Stop 抢先成功，返回 true；如果回调启动已经不可逆，返回 false。即使回调只执行了很短时间，Stop 也不会为调用方等待它返回。

需要等待时，为回调补一个完成信号

如果回调会访问连接、文件、缓存对象或其他需要在取消路径中释放的资源，不能写成“Stop 返回 false 就立即释放”。更稳妥的方式是让回调在退出时关闭一个完成 channel，取消方在无法阻止回调时等待它。

package main

import (
	"sync"
	"time"
)

type Delayed struct {
	timer      *time.Timer
	done       chan struct{}
	finishOnce sync.Once
}

func NewDelayed(delay time.Duration, work func()) *Delayed {
	d := &Delayed{done: make(chan struct{})}
	d.timer = time.AfterFunc(delay, func() {
		defer d.finishOnce.Do(func() { close(d.done) })
		// work 可能与 StopAndWait 并发，内部共享状态仍要自行加锁或使用原子操作。
		work()
	})
	return d
}

func (d *Delayed) StopAndWait() bool {
	stopped := d.timer.Stop()
	if stopped {
		// 回调没有启动，主动结束等待信号，避免调用方永久阻塞。
		d.finishOnce.Do(func() { close(d.done) })
		return true
	}

	// false 只说明不能再取消；这里等待已经启动的回调完成。
	

这里使用 sync.Once 是因为成功停止和回调收尾是两个竞争路径，都可能尝试关闭 done。它保证 channel 只关闭一次。调用方拿到 true 时，回调没有启动，可以直接结束；拿到 false 时，等待 done 才能把“定时器不可取消”推进到“回调已完成”。

共享状态仍然需要单独保护

完成信号只解决生命周期，不会自动消除数据竞争。如果 work 修改一个结构体，而取消路径同时读取它，应使用互斥锁或原子类型保护同一份状态；不要因为调用了 Stop 就默认回调不会再访问字段。

还要注意两类边界：

• 只需要“尽量取消”时，可以只检查 Stop 的返回值，不必强行等待；但不要在 false 分支提前销毁回调仍会使用的资源。
• 需要“取消后确认收尾”时，必须由回调发出完成信号，并把重复关闭、重复停止设计成幂等操作。

小结

AfterFunc 的回调与 Stop 之间存在天然竞态：true 只代表成功阻止启动，false 只代表已经无法取消；两者都不是“回调已经结束”的证明。把取消结果和完成结果拆成两个状态，再用 channel、sync.WaitGroup 或其他明确同步原语衔接，才能安全地完成资源清理。

常见问题

Stop 返回 false 后还要调用回调吗？

不需要手动调用。false 表示定时器已经到期或停止，回调可能已经由运行时启动；手动再调用会造成重复执行。

AfterFunc 的 Timer.C 能不能用来等待？

不能。函数型定时器的 C 不用于通知，应该由回调主动发送完成信号。

Stop 返回 true 后还需要等待 done 吗？

如果你的封装为“未启动回调”也关闭了 done，那么可以统一等待；示例中直接关闭 done 是为了避免等待者阻塞。

回调内部有共享变量怎么办？

完成信号只表示生命周期结束，访问共享变量仍需要互斥锁、原子操作或其他同步协议。