当前位置：首页 > 文章列表 > Golang > Go教程 > 控制Golang协程数量的实用方法

控制Golang协程数量的实用方法

2026-01-07 15:21:52 0浏览收藏

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Golang控制goroutine数量的技巧》，聊聊，希望可以帮助到正在努力赚钱的你。

不能无限制启动 goroutine，因每个goroutine需约2KB栈内存且调度开销大，易致内存耗尽、上下文切换频繁、HTTP超时及DB连接池打满；可用带缓冲channel实现限流。

Golang并发场景下如何控制goroutine数量

为什么不能无限制启动 goroutine

Go 的 goroutine 虽轻量，但每个仍需约 2KB 栈空间（可增长），大量并发会吃光内存；更关键的是，频繁调度、抢占、上下文切换本身会拖慢整体吞吐。常见现象是：代码看着“并发了”，实际 http.Client 超时变多、数据库连接池打满、context.DeadlineExceeded 错误突增——这往往不是 CPU 瓶颈，而是资源争用失控。

用带缓冲的 channel 实现最简限流器

这是最易理解、无第三方依赖的方案，本质是把“启动 goroutine”变成“从 channel 取令牌”的阻塞操作。

func runWithLimit(tasks []func(), maxConcurrent int) {
    sem := make(chan struct{}, maxConcurrent)
    for _, task := range tasks {
        sem 注意点：

sem 是带缓冲的 chan struct{}，容量即最大并发数
必须在 goroutine 内部 defer 释放令牌，否则 panic 或死锁
该写法不处理 panic：若 t() panic， 不会执行，令牌泄露

用 `sync.WaitGroup` + `semaphore` 库更稳妥

标准库没提供信号量，但 golang.org/x/sync/semaphore 是官方维护的可靠实现，支持带超时的获取、可取消、能统计当前使用量。

import "golang.org/x/sync/semaphore"
func runWithSemaphore(tasks []func(), maxConcurrent int) {
s := semaphore.NewWeighted(int64(maxConcurrent))
var wg sync.WaitGroup
for _, task := range tasks {
wg.Add(1)
go func(t func()) {
defer wg.Done()
if err := s.Acquire(context.Background(), 1); err != nil {
return // 如 context 被 cancel
}
defer s.Release(1)
t()
}(task)
}
wg.Wait()
}

优势：