应使用带缓冲的空结构通道实现信号量来控制goroutine并发上限，因runtime.GOMAXPROCS控制OS线程数而非goroutine数量，WaitGroup仅用于同步等待、无准入控制能力。
Go语言中协程（goroutine）轻量，但无节制启动仍会导致内存暴涨、调度开销上升甚至OOM。单纯靠业务逻辑“估算”并发数不可靠，用信号量（Semaphore）显式控制并发上限，是稳定、可观察、易调试的实践方案。
为什么不用 runtime.GOMAXPROCS 或 sync.WaitGroup？
runtime.GOMAXPROCS 控制的是OS线程数（P的数量），不是goroutine并发上限；它影响调度器并行能力，不直接限制同时运行的goroutine数量。
sync.WaitGroup 只用于等待一组goroutine结束，不具备“准入控制”能力——你无法在启动前判断是否该放行。它解决的是“同步”，不是“限流”。
用 chan struct{} 实现轻量信号量
最简洁可靠的信号量实现是带缓冲的空结构通道：make(chan struct{}, N)。发送一个 struct{} 占位表示获取许可，接收则归还许可。
- 初始化：定义容量为最大并发数（如50）的通道：
sem := make(chan struct{}, 50) - 获取许可：用
sem （阻塞直到有空位） - 释放许可：用
（从通道取走一个占位符） - 建议封装成方法，避免裸操作出错
封装成可复用的 Semaphore 类型
加一层类型和方法，提升可读性与安全性：
立即学习“go语言免费学习笔记（深入）”；
type Semaphore struct {
c chan struct{}
}
func NewSemaphore(n int) *Semaphore {
return &Semaphore{c: make(chan struct{}, n)}
}
func (s Semaphore) Acquire() { s.c <- struct{}{} }
func (s Semaphore) Release() { <-s.c }
func (s *Semaphore) TryAcquire() bool {
select {
case s.c <- struct{}{}:
return true
default:
return false
}
}
其中 TryAcquire 支持非阻塞尝试，适合超时丢弃或降级场景（如请求高峰时快速失败而非排队）。
结合 context 实现带超时/取消的获取
生产环境常需防止单个任务无限等待。用 context.WithTimeout 配合 select 可优雅处理：
func (s *Semaphore) AcquireCtx(ctx context.Context) error {
select {
case s.c <- struct{}{}:
return nil
case <-ctx.Done():
return ctx.Err()
}
}调用时：err := sem.AcquireCtx(context.WithTimeout(ctx, 3*time.Second))，超时即返回错误，业务可记录告警或走备选路径。
基本上就这些。信号量不是银弹，但它把“并发数”这个隐性约束显性化、可配置、可监控。配合 pprof 和 metrics 暴露当前占用数，就能真正掌控协程水位。
