C#如何使用SemaphoreSlim_C#限制并发线程数量的最佳实践【核心】
使用SemaphoreSlim高效管理并发数,核心是WaitAsync与Release必须成对出现,Release务必置于finally块中以防死锁。它采用异步挂起不占用线程,特别适合高并发场景。不同资源需各自独立实例,上限依据下游承载能力设定,同时不保证执行顺序。
直接说结论:用 SemaphoreSlim 来管理并发数,核心法则就是 WaitAsync() 和 Release() 必须成对出现,而且 Release() 必须放在 finally 里——只要漏掉一次,后面的请求就得永远排队等着,这是最要命的坑。
先聊聊一个很常见的错误观念:有人习惯用 lock 或者 Monitor 来限制并发,觉得效果差不多。其实差远了。lock 是同步原语,它的工作方式是让线程在那儿干等着,直到锁被释放。但我们现在要解决的问题是“同时发出去的请求太多”,而不是“谁先抢到 CPU 时间片”。举个例子,假如你一口气发起 1000 个 HTTP 请求,用 lock 很快就发现线程池撑不住了,系统响应时间直线上升。而 SemaphoreSlim 的 WaitAsync() 是异步挂起,不会占着线程,这才是配合 async/await 的正确姿势。
- 所以记住一条原则:
lock和Monitor适合保护内存里的共享变量(比如一个静态计数器),但不适合用来控制资源访问的节奏。 SemaphoreSlim初始化时传进去的那个数字就是硬上限。比如new SemaphoreSlim(4),意思是最多只有 4 个WaitAsync()能立刻返回,第 5 个就得老老实实等着前面有人调用Release()。- 而且它不依赖操作系统内核对象,比老式的
Semaphore开销小得多,特别适合用在高并发的 Web API 场景。
接下来是实操中最容易踩坑的地方:WaitAsync() 必须搭配 finally 块里的 Release()。道理很简单,一旦代码在执行过程中抛出异常,Release() 就没机会跑了,信号量的许可数就会永久少一个。哪怕你拿到了许可,但后续的操作(比如 HttpClient.SendAsync())突然抛出一个 HttpRequestException,如果不释放,这个坑就埋下了。
- 标准写法是这样:
await semaphore.WaitAsync(); try { /* 实际操作 */ } finally { semaphore.Release(); } - 千万别想着用
using包裹SemaphoreSlim,它不是那种用完就扔的资源型对象。Dispose()只会清理内部的 Task 状态,不影响计数逻辑。 - 也不要把
Release()放在catch块里——如果WaitAsync()因为超时而抛出了OperationCanceledException,说明你根本没拿到许可,这时候调Release()反而会触发ObjectDisposedException或者计数错乱。
再说说怎么为不同资源分配独立的 SemaphoreSlim 实例。一个信号量只能管一类资源,混在一起用会让逻辑变得混乱,排查问题也费劲。比如你用一个实例同时控制数据库连接和日志写入,哪天日志那边变慢了,结果整个订单处理流程都被拖垮,那就得不偿失了。
- 按资源的边界来隔离:数据库操作就用
_dbSemaphore = new SemaphoreSlim(10),外部 API 调用就用_apiSemaphore = new SemaphoreSlim(5)。 - 初始化时设置
maxCount,一定要参考下游系统的实际承载力。比如数据库连接池默认是 100,你设成 15 到 20 就比较安全;API 限流常见是 3 到 10,这样不容易被远端返回 429 拒绝。 - 别习惯性地把它设成 CPU 核心数。在 I/O 密集型场景(比如 HTTP 请求、数据库读写)里,瓶颈往往不在 CPU,而是网络带宽、连接池的大小或者远方服务的响应能力。
最后补充一个容易被忽视的细节:SemaphoreSlim 不保证执行顺序,也不防重入。它的职责很简单,就是决定“同时能进去多少个”,并不理会“谁先进去”。默认是非公平的,在高并发下,后发起请求的线程反而可能先拿到许可。另外,同一个线程可以反复多次调用 WaitAsync()(这就是重入),但每一次都得对应一次 Release(),否则照样泄漏。
- 如果你对顺序有严格要求,比如必须先进先出,那得自己加队列并通过
TaskCompletionSource手动排队,SemaphoreSlim本身不提供这个能力。 - 重入的场景并不少见。比如某个服务方法内部调用了另一个也受同一信号量保护的方法,这时候就要小心嵌套等待可能引发的死锁。
- 从性能上看,
SemaphoreSlim在千级并发下依然很高效。但如果发现单次WaitAsync()的平均等待时间超过了 100 毫秒,那就说明你设的并发数太小了,该考虑调大上限了。

说到底,写对那几行代码其实不难,真正考验人的是想清楚一个问题:这个信号量到底在保护什么资源?它的上限由谁来决定?是数据库连接池的承受能力,是第三方 API 给你的配额,还是你自己服务器上的内存水平?边界定错了,代码写得再严谨,也只能在错误的路上越走越远。
































