如何在 Go 中编写一个并发限制 (Semaphores) 执行的函数-Golang-PHP中文网

go 无内置信号量，但可用带缓冲的 chan struct{} 模拟：初始化 sem := make(chan struct{}, maxconcurrency)，取令牌用

如何在 go 中编写一个并发限制 (semaphores) 执行的函数

Go 里没有内置的 `semaphore`，但可以用 `chan struct{}` 模拟

Go 标准库不提供传统意义上的信号量（如 POSIX semaphore），但用带缓冲的 channel 实现一个轻量、线程安全的并发限制器非常自然。核心思路是：把 channel 当作“令牌池”，每次执行前取一个 token，执行完放回一个。

常见错误是误用无缓冲 channel（make(chan struct{})）——它只能串行；或缓冲大小设错，导致实际并发数和预期不符。

初始化：sem := make(chan struct{}, maxConcurrency)，其中 maxConcurrency 就是你想限制的最大 goroutine 数
获取许可：sem （阻塞直到有空位）
释放许可：（从 channel 取出一个 token，相当于归还）
注意：必须确保每个 都有对应 <code>sem ，否则会死锁

封装成可复用的 `Limit` 函数，支持超时和 panic 安全

直接裸写 channel 操作容易漏掉释放逻辑，尤其遇到 panic 或提前 return。推荐封装为函数，用 defer 保证释放。

func Limit(max int, f func()) {
    sem := make(chan struct{}, max)
    sem <p>但这样每次调用都要新建 channel，开销大。更实用的是预建一个全局或局部 <code>sem</code>，然后在闭包中复用：</p>

超时控制：用 select + time.After 避免无限等待 sem
panic 安全：用 recover() + defer 确保即使 f() panic，token 也能归还
不要把 sem 传给多个 goroutine 后随意 close —— close 后再写入会 panic

用 `golang.org/x/sync/semaphore` 替代手写（Go 1.21+ 推荐）

如果你用的是 Go 1.21 或更新版本，标准生态已提供官方维护的信号量实现：golang.org/x/sync/semaphore。它比手写 channel 更健壮，支持带上下文的 acquire、支持权重（acquire 多个 unit）、支持 cancel 和 timeout。

Qclaw

一款AI开发辅助工具，主要用于腾讯电脑管家打造的桌面智能体AI助手，随时随地，微信一下，Qclaw帮你搞定一切，适合需要提升相关任务效率的用户。

下载

典型用法：

import "golang.org/x/sync/semaphore"
<p>sem := semaphore.NewWeighted(int64(max))
ctx := context.Background()
if err := sem.Acquire(ctx, 1); err != nil {
// 超时或被 cancel
return
}
defer sem.Release(1)</p><p>f()</p>