C#怎么使用SemaphoreSlim C#限制并发线程数量方法

技术百科 月夜之吻 发布时间:2025-12-21 浏览:
SemaphoreSlim 是 C# 中专为异步设计的轻量信号量,通过 WaitAsync() 和 Release() 控制并发,需用 try/finally 确保释放,不支持 using,适用于单进程内限流。

SemaphoreSlim 是 C# 中轻量级的信号量实现,专为异步场景设计,适合控制并发访问资源的线程/任务数量。它比传统的 Semaphore 更高效(不依赖操作系统内核),且原生支持 async/await

初始化并设置最大并发数

构造函数接收两个参数:初始可进入数(通常等于最大并发数)、最大允许数。

  • 比如限制最多 3 个任务同时执行: var semaphore = new SemaphoreSlim(3, 3);
  • 第一个参数是“当前可用许可数”,第二个是“上限”,两者相等表示初始全空闲
  • 若设为 new SemaphoreSlim(0, 3),则初始无人能进入,需手动 Release() 才能开始

在异步方法中安全获取和释放许可

务必用 await WaitAsync() 获取许可,用 Release() 归还(不能用 await ReleaseAsync(),它不存在)。

  • 推荐写法(自动释放,防遗漏):
await semaphore.WaitAsync();
try
{
    // 执行受控操作,如调用 API、处理文件等
    await DoWorkAsync();
}
finally
{
    semaphore.Release(); // 必须确保执行到
}
  • 别用 using —— SemaphoreSlim 不实现 IDisposable(仅当需要释放底层资源时才调用 Dispose(),一般不用)
  • 避免在 catch 块外直接 Release(),否则异常时会漏释放,导致许可永久丢失

配合 Task.WhenAll 控制批量任务并发

常见需求:启动 100 个 HTTP 请求,但只允许最多 5 个并发。

  • 把所有任务拆成小批次,或用循环 + WaitAsync 控制节奏
  • 简洁做法(逐个提交,内部限流):
var tasks = urls.Select(async url =>
{
    await semaphore.WaitAsync();
    try
    {
        return await client.GetStringAsync(url);
    }
    finally
    {
        semaphore.Release();
    }
});
await Task.WhenAll(tasks);
  • 注意:上面写法本质是“启动 100 个任务,但每个都先抢许可”,实际并发仍可控
  • 如果想更明确分批(如每批 5 个),可用 Chunk() + Task.WhenAll 嵌套

其他实用细节

  • WaitAsync() 可传入 CancellationToken,支持取消等待(比如超时或用户中止)
  • CurrentCount 属性可读取当前剩余许可数(仅作监控,非原子判断依据)
  • 不要在同步方法里用 Wait() 阻塞等待 —— 容易引发死锁,尤其在 UI 或 ASP.NET 同步上下文中
  • 若需跨进程或跨 AppDomain 限流,SemaphoreSlim 不适用,得换 Semaphore 或分布式方案(如 Redis 信号量)

基本上就这些。SemaphoreSlim 不复杂但容易忽略释放和异常路径,只要守好“try/finally + Release”这个模式,就能稳稳控住并发量。


# ai  # 操作系统  # 就能  # 第一个  # 最多  # 适用于  # 第二个  # 专为  # app  # 设为  # 不支持  # redis  # ui  # http  # 循环  # 并发  # c#  # 构造函数  # .net  # 线程  # 异步  # 死锁  # red  # var  # try  # catch  # finally  # using  # 分布式  # 并发访问  # 信号量 


相关栏目: <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 AI推广<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 SEO优化<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 技术百科<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 谷歌推广<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 百度推广<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 网络营销<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 案例网站<?muma echo $count; ?> 】 <?muma $count = M('archives')->where(['typeid'=>$field['id']])->count(); ?> 【 精选文章<?muma echo $count; ?>

相关推荐

在线咨询

点击这里给我发消息QQ客服

在线咨询

免费通话

24h咨询:4006964355


如您有问题,可以咨询我们的24H咨询电话!

免费通话

微信扫一扫

微信联系
返回顶部