任务生命周期需定义Start、Stop、Restart、Wait四个核心状态与接口，其中Start启动任务并监听context.Done()，Stop幂等发出取消信号，Wait阻塞等待goroutine完全退出，且均需线程安全、可重入；Stop与Wait必须解耦，配合sync.WaitGroup和done channel确保清理完成，避免竞态与泄漏。
任务生命周期需要哪些核心状态和接口
Go 里没有内置的“任务生命周期”抽象，得自己定义清楚 Start、Stop、Restart、Wait 这几个动作的语义边界。常见错误是把 Stop 写成无条件 os.Exit 或直接 close channel，导致调用方无法等待清理完成。
推荐用接口统一行为，比如：
type Task interface {
Start() error
Stop() error
Wait() error // 阻塞直到内部 goroutine 完全退出
}
注意 Wait 必须可重入且线程安全——多个 goroutine 同时调用不能 panic；Stop 应该幂等，重复调用不报错也不重复触发清理逻辑。
用 context.Context 控制启动与取消
别自己造信号量或全局 flag 来控制运行状态。Go 的标准方式是把 context.Context 作为 Start 的参数，让任务内部监听 ctx.Done() 触发退出流程。
立即学习“go语言免费学习笔记（深入）”；
典型陷阱：
-
context.WithCancel创建的 ctx 被意外泄露（比如没 defer cancel），导致 goroutine 泄漏 - 在
Start中启动 goroutine 后没做 recover，panic 会让整个任务静默失败 - 忘记在
Stop里调用 cancel 函数，导致Wait永远阻塞
正确姿势示例：
func (t *MyTask) Start(ctx context.Context) error {
t.mu.Lock()
if t.running {
t.mu.Unlock()
return errors.New("task already running")
}
t.cancelCtx, t.cancel = context.WithCancel(ctx)
t.running = true
t.mu.Unlock()
go func() {
defer func() {
if r := recover(); r != nil {
log.Printf("task panicked: %v", r)
}
}()
t.run(t.cancelCtx) // 实际工作逻辑，内部 select ctx.Done()
}()
return nil
}
Stop 和 Wait 怎么配合避免竞态
关键点在于：Stop 只负责发出停止信号，Wait 才真正等待结束。两者必须解耦，否则容易出现 Stop 返回了但 goroutine 还在跑，或者 Wait 被误认为是同步阻塞调用。
常用模式是用 sync.WaitGroup + chan struct{} 组合：
-
Stop调用t.cancel()并close(t.done) -
Wait调用t.wg.Wait()，而每个工作 goroutine 在退出前执行t.wg.Done() -
donechannel 仅用于通知“已开始退出”，不是“已退出完毕”
别省略 WaitGroup —— 仅靠 close(done) 无法保证所有子 goroutine 都已完成清理。
如何让模块可复用：避免硬编码依赖
写死日志、配置加载、指标上报这些，会锁死模块的复用场景。应该把它们抽成函数参数或接口字段：
- 日志用
log.Logger或自定义Logger接口，而非直接 importlog - 配置通过构造函数传入结构体，而不是读取
os.Getenv或flag - 指标暴露用回调函数，例如
OnMetric(func(name string, value float64))，而非绑定 Prometheus registry
这样别人引入你的模块时，才能无缝接入自己的可观测体系。否则一用就报错 prometheus.MustRegister: metric already registered 或日志输出格式不一致。
一个容易被忽略的细节：模块的 struct 字段尽量设为 unexported（小写），只暴露方法，防止外部直接修改内部状态引发竞态。
