C#使用SemaphoreSlim實現(xiàn)并發(fā)控制與限流策略的實戰(zhàn)指南
更新時間：2025年11月12日 09:05:24 作者：拾荒的小海螺
在現(xiàn)代應用中（如爬蟲、并發(fā)請求、數(shù)據(jù)庫連接池、異步任務處理）,我們常常需要限制同時執(zhí)行的任務數(shù)量,以避免過載或資源競爭,在 C# 中,最簡潔高效的解決方案之一就是SemaphoreSlim,本文就給大家介紹了C#使用SemaphoreSlim實現(xiàn)并發(fā)控制與限流策略的實戰(zhàn)指南
1、簡述
在現(xiàn)代應用中（如爬蟲、并發(fā)請求、數(shù)據(jù)庫連接池、異步任務處理），我們常常需要限制同時執(zhí)行的任務數(shù)量，以避免過載或資源競爭。
在 C# 中，最簡潔高效的解決方案之一就是 —— SemaphoreSlim。
2、基本原理
SemaphoreSlim 內(nèi)部維護一個“許可計數(shù)（Permit Count）”。
每個線程執(zhí)行前需要調(diào)用 Wait()（或 WaitAsync()）來獲取許可，執(zhí)行結束后調(diào)用 Release() 歸還許可。
當所有許可被占用時，新線程會等待，直到有資源釋放。Semaphore 與 SemaphoreSlim 都用于控制并發(fā)訪問，但它們的實現(xiàn)和性能不同。
| 對比項 | Semaphore | SemaphoreSlim |
|---|---|---|
| 實現(xiàn)方式 | 內(nèi)核對象（較重） | 用戶態(tài)輕量實現(xiàn)（高性能） |
| 是否跨進程 | ? 是 | ? 否 |
| 是否支持 async/await | ? 否 | ? 是 |
| 推薦場景 | 跨進程同步 | 應用內(nèi)并發(fā)控制 |
結論： 在現(xiàn)代 C# 應用中（如 Web API、后臺任務、異步 I/O），使用 SemaphoreSlim 是首選。
3、實踐樣例
3.1 基本用法
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static SemaphoreSlim semaphore = new SemaphoreSlim(3); // 最多3個并發(fā)
static async Task Main()
{
var tasks = new Task[10];
for (int i = 0; i < 10; i++)
{
int id = i;
tasks[i] = Task.Run(() => DoWorkAsync(id));
}
await Task.WhenAll(tasks);
Console.WriteLine("全部任務完成！");
}
static async Task DoWorkAsync(int id)
{
await semaphore.WaitAsync(); // 獲取許可
try
{
Console.WriteLine($"任務 {id} 開始，當前時間：{DateTime.Now:T}");
await Task.Delay(1000); // 模擬工作
Console.WriteLine($"任務 {id} 結束。");
}
finally
{
semaphore.Release(); // 釋放許可
}
}
}
輸出示例：
任務 0 開始... 任務 1 開始... 任務 2 開始... 任務 3 等待中... 任務 0 結束。 任務 3 開始... ...
說明：同時最多 3 個任務在運行。
3.2 限制并發(fā)的 HTTP 請求（爬蟲場景）
using System;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
class WebCrawler
{
static readonly HttpClient httpClient = new HttpClient();
static readonly SemaphoreSlim semaphore = new SemaphoreSlim(5); // 最多5個并發(fā)
static async Task Main()
{
var urls = new[]
{
"https://example.com",
"https://dotnet.microsoft.com",
"https://github.com",
"https://openai.com",
"https://google.com",
"https://bing.com"
};
var tasks = new Task[urls.Length];
for (int i = 0; i < urls.Length; i++)
{
string url = urls[i];
tasks[i] = ProcessUrlAsync(url);
}
await Task.WhenAll(tasks);
Console.WriteLine("所有請求完成！");
}
static async Task ProcessUrlAsync(string url)
{
await semaphore.WaitAsync();
try
{
Console.WriteLine($"開始請求：{url}");
var response = await httpClient.GetAsync(url);
Console.WriteLine($"{url} 返回狀態(tài)碼：{response.StatusCode}");
}
finally
{
semaphore.Release();
}
}
}
效果：同一時間最多有 5 個請求在執(zhí)行，防止網(wǎng)絡或服務器過載。
3.3 控制文件寫入任務
多個線程同時寫同一個文件時，可以用 SemaphoreSlim 控制訪問速率。
using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
class FileWriter
{
static SemaphoreSlim semaphore = new SemaphoreSlim(1); // 一次僅允許1個線程寫文件
static async Task Main()
{
var tasks = new Task[5];
for (int i = 0; i < 5; i++)
{
int id = i;
tasks[i] = Task.Run(() => WriteLogAsync(id));
}
await Task.WhenAll(tasks);
Console.WriteLine("寫入完成。");
}
static async Task WriteLogAsync(int id)
{
await semaphore.WaitAsync();
try
{
await File.AppendAllTextAsync("output.txt", $"線程 {id} 在 {DateTime.Now}\n");
Console.WriteLine($"線程 {id} 寫入完成");
}
finally
{
semaphore.Release();
}
}
}
結果：日志文件不會被多個線程同時寫入而損壞。
3.4 帶超時機制的并發(fā)控制
如果等待太久無法獲取資源，可設置超時防止卡死。
if (await semaphore.WaitAsync(TimeSpan.FromSeconds(2)))
{
try
{
Console.WriteLine("成功獲取資源。");
}
finally
{
semaphore.Release();
}
}
else
{
Console.WriteLine("等待超時，放棄操作。");
}
3.5 在異步隊列中控制消費者數(shù)量
適用于后臺任務或消息隊列處理。
using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
class QueueProcessor
{
static SemaphoreSlim semaphore = new SemaphoreSlim(3); // 同時處理3個任務
static BlockingCollection<int> queue = new BlockingCollection<int>();
static async Task Main()
{
// 模擬生產(chǎn)者
Task.Run(() =>
{
for (int i = 0; i < 10; i++)
{
queue.Add(i);
Console.WriteLine($"生產(chǎn)任務 {i}");
Thread.Sleep(200);
}
queue.CompleteAdding();
});
// 消費者
var consumers = new Task[3];
for (int i = 0; i < consumers.Length; i++)
{
consumers[i] = Task.Run(() => ConsumeAsync(i));
}
await Task.WhenAll(consumers);
Console.WriteLine("隊列處理完成。");
}
static async Task ConsumeAsync(int workerId)
{
foreach (var item in queue.GetConsumingEnumerable())
{
await semaphore.WaitAsync();
try
{
Console.WriteLine($"工作線程 {workerId} 處理任務 {item}");
await Task.Delay(500);
}
finally
{
semaphore.Release();
}
}
}
}
效果：任務生產(chǎn)速度可以高于消費速度，但消費者數(shù)量始終受控，防止系統(tǒng)過載。
4、總結
通過本文，你已經(jīng)掌握了：
SemaphoreSlim的核心原理與區(qū)別；- 如何控制并發(fā)訪問；
- 在異步任務、HTTP 請求、文件 I/O 等場景下的實戰(zhàn)用法；
- 如何結合超時與限流策略提高系統(tǒng)穩(wěn)定性。
| 場景 | 說明 |
|---|---|
| 并發(fā) HTTP 請求控制 | 限制同時發(fā)起的請求數(shù) |
| 數(shù)據(jù)庫連接池 | 限制連接數(shù)量，防止連接耗盡 |
| 圖片處理任務 | 限制 CPU 密集型任務數(shù) |
| 異步隊列消費 | 避免后臺任務過載 |
| API 限流 | 防止接口被濫用或打爆 |
SemaphoreSlim 是現(xiàn)代 .NET 并發(fā)編程中非常實用的工具， 能讓你輕松實現(xiàn)資源保護、限流與異步協(xié)作。
以上就是C#使用SemaphoreSlim實現(xiàn)并發(fā)控制與限流策略的實戰(zhàn)指南的詳細內(nèi)容，更多關于C# SemaphoreSlim并發(fā)控制與限流策略的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要為大家詳細介紹了C#如何使用selenium組件實現(xiàn)操作瀏覽器并且截圖,文中的示例代碼簡潔易懂,有需要的小伙伴可以參考一下2024-01-01
這篇文章主要介紹了詳解c#與js的rsa加密互通，幫助大家更好的理解和學習使用c#，感興趣的朋友可以了解下2021-03-03
這篇文章主要介紹了C#設置開機啟動項、取消開機啟動項,本文通過修改注冊實現(xiàn),并給出操作代碼,需要的朋友可以參考下2015-06-06
這篇文章介紹了字符串和十六進制之間的轉換方法實例，有需要的朋友可以參考一下2013-11-11
下面小編就為大家?guī)硪黄狢# 實例化接口對象的方法。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-02-02
這篇文章主要為大家詳細介紹了C#創(chuàng)建WCF服務控制臺應用程序，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-07-07
在本篇文章里小編給大家整理的是關于C#線程同步的幾種方法總結，需要的朋友們可以學習下。2020-02-02
RSA解決了對稱加密的一個不足，比如AES算法加密和解密時使用的是同一個秘鑰，因此這個秘鑰不能公開，因此對于需要公開秘鑰的場合，我們需要在加密和解密過程中使用不同的秘鑰，加密使用的公鑰可以公開，解密使用的私鑰要保密，這就是非對稱加密的好處?！?/div> 2021-06-06
這篇文章主要介紹了C#、vb.net及SQL判斷指定年份是否為閏年的方法,分別以三種方法實現(xiàn)了判斷閏年的功能,在進行項目開發(fā)中具有一定的參考借鑒價值,需要的朋友可以參考下2014-11-11
這篇文章主要介紹了C#中的事務用法,以一個簡單實例形式分析了C#創(chuàng)建及使用事物的相關技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-09-09最新評論