控制goroutine数量的关键是按需调度与有效复用，需依任务类型选择模型：IO密集型可放宽并发，CPU密集型应限为NumCPU()，混合型宜拆分处理，并通过带缓冲channel与固定worker池实现可控并发。
控制 goroutine 数量的核心不是“限制启动”，而是“按需调度 + 有效复用”。盲目设置固定上限容易导致吞吐下降或阻塞，真正关键的是理解任务类型、合理使用池化与信号控制。
根据任务类型选择并发模型
IO 密集型（如 HTTP 请求、数据库查询）可适度放宽并发数，因大部分时间在等待；CPU 密集型（如图像处理、加密计算）应严格限制，通常不超过 runtime.NumCPU()。混合型任务建议拆分：IO 部分走异步，CPU 部分进 worker 池。
- HTTP 客户端调用：用 http.Client.Transport.MaxIdleConnsPerHost 控制连接复用，而非起大量 goroutine
- 批量文件处理：先用 sync.Pool 复用解析缓冲区，再通过固定 size 的 worker channel 分发任务
用带缓冲的 channel + 固定 worker 池管理并发
这是最常用且可控的方式：启动 N 个长期运行的 goroutine 消费任务，所有请求统一入队，避免瞬时爆发创建海量协程。
func NewWorkerPool(n int) *WorkerPool {
pool := &WorkerPool{
jobs: make(chan Job, 1000), // 缓冲区防阻塞
results: make(chan Result, 1000),
}
for i := 0; i < n; i++ {
go pool.worker()
}
return pool
}
func (p *WorkerPool) worker() {
for job := range p.jobs {
result := job.Do()
p.results <- result
}
}
用 context 和 select 实现超时与取消
每个 goroutine 应响应取消信号，避免“幽灵协程”堆积。尤其在链路调用中，父 context 取消后子 goroutine 必须退出。
立即学习“go语言免费学习笔记（深入）”；
- 启动 goroutine 时传入 ctx，并在关键阻塞点（如 channel receive、time.Sleep、http.Do）用 select { case
- 避免在 goroutine 内部无条件 sleep 或死循环，除非有 ctx.Done() 检查
- 数据库查询、RPC 调用等务必设置 context.WithTimeout，防止一个慢请求拖垮整组协程
监控与动态调优（非硬编码上限）
上线后观察 runtime.NumGoroutine()、GC 频率、goroutine 平均生命周期。若长期维持在数千以上且增长不收敛，说明存在泄漏或调度失衡。
- 用 pprof.GoroutineProfile 抓取堆栈，定位未退出的 goroutine
- 对高优先级任务用独立 pool，低频任务用 lazy 初始化 pool，避免常驻资源浪费
- 可结合 prometheus 暴露 goroutine 数、任务排队时长等指标，触发自动扩缩（如根据 pending job 数动态增减 worker）
