Go 中无法强制终止 goroutine，必须依赖其主动退出；使用 context.Context 是官方推荐的优雅关闭方式，需通过 select 监听 ctx.Done() 实现取消通知。
Go 无法强制杀掉 goroutine，必须靠它自己退出 —— 所有“优雅关闭”的本质，就是让 goroutine 主动感知退出信号、完成清理、然后 return。
用 context.Context 通知退出最通用
这是官方推荐、跨包协作最稳妥的方式，尤其适合有父子关系或超时/取消需求的场景。比如 HTTP handler、数据库连接池、定时任务等。
-
context.WithCancel用于手动触发退出；context.WithTimeout或context.WithDeadline自动带超时逻辑 - goroutine 内必须用
select监听ctx.Done()，不能只轮询ctx.Err()（会忙等） - 不要把
context.Background()直接传给长期运行的 goroutine —— 它永远不 cancel，等于放弃控制权
func worker(ctx context.Context) {
for {
select {
case <-ctx.Done():
fmt.Println("worker exiting:", ctx.Err())
return
default:
// do real work, e.g. process one item
time.Sleep(100 * time.Millisecond)
}
}
}
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
defer cancel() // 防止忘记调用
go worker(ctx)
// 等待 worker 自己退出
time.Sleep(3 * time.Second)
}
用 chan struct{} 关闭平级 goroutine 最轻量
当多个 goroutine 是对等关系、无上下文传递需求（比如一组独立的消费者），用关闭的 channel 是最简洁直接的选择 —— 它零内存开销、语义清晰、无需 import 额外包。
立即学习“go语言免费学习笔记（深入）”；
- 必须用
struct{}类型（而非bool或int），因为它是零大小，且明确表示“只传信号，不传数据” - 关闭 channel（
close(ch)）比向其发送值更安全：避免接收方漏信号（尤其是无缓冲 channel）；所有监听者都能立即收到退出通知 - 别用
for range ch来驱动无限循环 goroutine —— channel 关闭后range会自动退出，但你通常需要在退出前做清理
func worker(stopCh <-chan struct{}) {
defer fmt.Println("worker cleaned up and exited")
for {
select {
case <-stopCh:
return // exit cleanly
default:
time.Sleep(200 * time.Millisecond)
}
}
}
func main() {
stopCh := make(chan struct{})
go worker(stopCh)
time.Sleep(1 * time.Second)
close(stopCh) // 所有监听 stopCh 的 goroutine 都能立刻感知
time.Sleep(500 * time.Millisecond)
}
用 sync.WaitGroup 确保全部退出完成
WaitGroup 不负责“通知退出”，只负责“等待退出完成”。它必须和 context 或 channel 配合使用，否则主 goroutine 会永远卡在 wg.Wait() 上。
- 每个 goroutine 启动前调用
wg.Add(1)，退出前必须调用wg.Done()（建议用defer wg.Done()） - 如果 goroutine 因 panic 退出，
Done()没执行，wg.Wait()就会死锁 —— 生产环境务必加 recover 或确保逻辑不会 panic - 别在循环里反复
wg.Add(1)却只调一次Done()，会导致计数不匹配
func main() {
var wg sync.WaitGroup
stopCh := make(chan struct{})
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for {
select {
case <-stopCh:
fmt.Printf("worker %d exiting/n", id)
return
default:
time.Sleep(time.Second)
}
}
}(i)
}
time.Sleep(2 * time.Second)
close(stopCh)
wg.Wait() // 确保三个都 clean exit 后才继续
fmt.Println("all workers done")
}
信号捕获 + 多层协调是生产服务标配
真实服务（如 Web server、消息消费者）必须同时处理 OS 信号（SIGINT/SIGTERM）、内部 goroutine 协调、超时兜底 —— 缺一不可。
- 用
signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)接收 Ctrl+C 或 systemd 停止指令 - 收到信号后，先发退出通知（如
cancel()或close(stopCh)），再wg.Wait()，最后可选加select+time.After防卡死 - 切忌在 signal handler 里直接调
os.Exit()—— 它跳过 defer 和 goroutine 清理，必然丢数据、连不上 DB、文件写一半
最易被忽略的一点：goroutine 里的阻塞操作（如 http.Get、conn.Read、time.Sleep）必须也支持 context 取消，否则通知发了它也收不到 —— 这类调用几乎都提供带 Context 的变体（如 http.NewRequestWithContext、conn.SetReadDeadline 配合 select）。