Go语言通过goroutine实现高并发，但需合理控制其创建与调度以提升性能。1. 复用goroutine：使用协程池减少GC和调度开销，通过固定worker从任务队列（channel）取任务执行，实现平滑处理与并发限制。2. 控制并发数量：利用带缓冲channel作信号量，限制同时运行的goroutine数，防止资源耗尽，结合WaitGroup和context实现等待与取消。3. 优化调度行为：避免长时间阻塞操作，主动让出CPU，减少锁竞争，使用非阻塞或多路复用提高响应性，适当sleep或yield释放调度机会，CPU密集型任务配合GOMAXPROCS充分利用多核。4. 监控与诊断：通过/debug/pprof/goroutine、expvar或Prometheus监控协程数，检查泄漏，结合trace分析调度问题。核心是按需创建、控制规模、复用资源，保障服务稳定与高吞吐。
Go语言的goroutine是实现高并发的核心机制，相比操作系统线程，它轻量得多。但频繁创建大量goroutine仍可能带来内存消耗和调度压力。合理控制goroutine的创建与调度，能显著提升程序性能和稳定性。
复用goroutine：使用协程池
频繁创建和销毁goroutine会增加GC负担和调度开销。通过协程池可以复用已有的goroutine，避免重复开销。
常见做法是启动固定数量的工作协程，通过任务队列接收任务并处理：
- 初始化一组长期运行的worker goroutine
- 使用无缓冲或有缓冲channel传递任务
- 每个worker从channel读取任务并执行
- 任务提交方无需每次新建goroutine
type Task func()var taskCh = make(chan Task, 1000) func worker() { for t := range taskCh { t() } }
func init() { for i := 0; i < 10; i++ { // 启动10个worker go worker() } }
func Submit(t Task) { taskCh <- t }
这样可以把突发任务流平滑处理，同时限制最大并发数。
立即学习“go语言免费学习笔记（深入）”；
控制并发数量：避免资源耗尽
不加节制地启动goroutine可能导致内存暴涨或上下文切换频繁。应根据实际负载设置并发上限。
常用方式包括：
- 使用带缓冲的channel作为信号量，控制活跃goroutine数量
- 利用sync.WaitGroup等待所有任务完成
- 结合context实现超时或取消传播
semaphore := make(chan struct{}, 50)
for _, task := range tasks {
semaphore <- struct{}{}
go func(t func()) {
defer func() { <-semaphore }()
t()
}(task)
}
这种模式简单有效，适用于批量处理场景。
优化调度行为：减少阻塞与抢占
Go调度器基于M:P:G模型，合理编写代码可提升调度效率。
注意以下几点：
- 避免在goroutine中执行长时间阻塞系统调用（如密集计算），必要时通过runtime.Gosched()主动让出CPU
- 减少锁竞争，避免因互斥导致goroutine阻塞在等待队列
- 尽量使用非阻塞操作或select多路复用，提高响应性
- 避免在循环中持续占用CPU，适当sleep或yield
对于CPU密集型任务，可考虑配合设置GOMAXPROCS，充分利用多核。
监控与诊断：及时发现问题
生产环境中应关注goroutine状态。可通过以下手段监测：
- 访问/debug/pprof/goroutine获取当前协程数和堆栈
- 使用expvar或Prometheus暴露goroutine计数指标
- 定期检查是否存在泄漏（持续增长不下降）
发现异常时，结合trace工具分析调度行为，定位卡顿或堆积原因。
基本上就这些。关键是按需创建、控制规模、复用资源。不复杂但容易忽略。做好了，服务稳定性和吞吐都能提升。
