.NET中的SemaphoreSlim是什么？如何限制对资源的并发访问数量？

小老鼠 2025-11-23 00:00:00 次阅读

SemaphoreSlim通过许可证机制限制并发数，如示例中最多3个线程同时访问资源：初始化指定最大并发数，线程调用WaitAsync()获取许可证，使用后Release()释放，避免阻塞或死锁，适用于控制数据库连接、任务并行等场景。

SemaphoreSlim 是 .NET 中用于控制对有限资源的并发访问数量的轻量级同步原语。它允许多个线程进入，但限制同时运行的线程总数，适用于需要控制并发度的场景，比如限制数据库连接数、控制任务并行数量等。

基本原理

SemaphoreSlim 类似于“许可证”机制：初始化时指定最大并发数（即许可证总数）。线程在访问资源前必须先获取一个许可证，使用完后再释放。如果所有许可证都被占用，后续线程将被阻塞或等待，直到有线程释放许可证。

如何使用 SemaphoreSlim 限制并发访问

以下是一个典型的使用示例，展示如何限制最多 3 个线程同时访问某个资源：

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    // 最多允许 3 个线程同时访问
    private static SemaphoreSlim _semaphore = new SemaphoreSlim(3);

    static async Task Main()
    {
        var tasks = new Task[10];
        for (int i = 0; i < 10; i++)
        {
            int id = i;
            tasks[i] = Task.Run(() => AccessResource(id));
        }

        await Task.WhenAll(tasks);
    }

    static async Task AccessResource(int id)
    {
        Console.WriteLine($"线程 {id} 正在等待进入...");

        // 等待获取许可证
        await _semaphore.WaitAsync();

        try
        {
            Console.WriteLine($"线程 {id} 进入，开始执行。");
            await Task.Delay(1000); // 模拟工作
        }
        finally
        {
            // 释放许可证
            _semaphore.Release();
            Console.WriteLine($"线程 {id} 退出，释放资源。");
        }
    }
}