c# 如何用 SemaphoreSlim 实现一个异步资源池

来源：这里教程网时间：2026-02-21 17:39:00 作者：

为什么不用

SemaphoreSlim

直接当资源池用

SemaphoreSlim

本身只管「并发数限制」，不管理资源的创建、复用、释放或生命周期。它像一把锁，但没配钥匙串——你得自己维护资源实例列表，决定谁拿哪把钥匙、用完是否归还、超时怎么处理。

常见误区是直接用

WaitAsync()

+ 全局静态资源对象，结果多个请求共享同一实例，引发状态污染或线程不安全。

资源需支持并发访问（如线程安全的缓存客户端），或必须按请求隔离（如数据库连接） 资源初始化可能耗时或失败，不能在
WaitAsync()
里同步阻塞做空闲资源该回收吗？最大/最小实例数怎么设？这些
SemaphoreSlim
一概不管

手动实现一个带租借语义的异步资源池

核心思路：用

SemaphoreSlim

控制「同时最多多少个资源被租出」，再用

ConcurrentQueue<t></t>

管理空闲资源实例，租借时优先取空闲项，没有则新建；归还时放回队列（除非已达空闲上限）。

以下是一个轻量级实现的关键逻辑（省略异常重试和完整 Dispose）：

public class AsyncResourcePool<T> where T : class
{
    private readonly Func<CancellationToken, Task<T>> _factory;
    private readonly Action<T> _disposer;
    private readonly int _maxSize;
    private readonly ConcurrentQueue<T> _idle = new();
    private readonly SemaphoreSlim _semaphore;
    public AsyncResourcePool(Func<CancellationToken, Task<T>> factory, Action<T> disposer, int maxSize = 10)
    {
        _factory = factory;
        _disposer = disposer;
        _maxSize = maxSize;
        _semaphore = new SemaphoreSlim(maxSize, maxSize);
    }
    public async Task<T> RentAsync(CancellationToken ct = default)
    {
        await _semaphore.WaitAsync(ct).ConfigureAwait(false);
        try
        {
            if (_idle.TryDequeue(out var item))
                return item;
            return await _factory(ct).ConfigureAwait(false);
        }
        catch
        {
            _semaphore.Release();
            throw;
        }
    }
    public void Return(T item)
    {
        if (item == null) return;
        // 可选：限制空闲池大小，避免内存堆积
        if (_idle.Count < _maxSize)
        {
            _idle.Enqueue(item);
        }
        else
        {
            _disposer(item);
        }
        _semaphore.Release();
    }
}

RentAsync

和

Return

的调用姿势与陷阱

必须成对出现，且

Return

不能漏掉，否则信号量永远不释放，池会死锁。推荐用

try/finally

或

using

（配合

IDisposable

包装器）。

不要在
RentAsync
后 await 长时间操作再
Return
——这会占用池位太久，压垮吞吐
Return
里别抛异常，否则
_semaphore.Release()
可能不执行；如有清理逻辑失败，应吞掉或记录日志如果资源类型本身是
IDisposable
，
_disposer
应调用
Dispose()
，而不是仅置空引用避免在
_factory
中捕获并“静默”异常——租借失败应让上层知道，而不是返回 null 或默认实例

实际用例：HTTP 客户端实例池（非

IHttpClientFactory

场景）

比如你需要大量短时、隔离的

HttpClient

实例（例如每个租户专用证书），又不想用

IHttpClientFactory

（因 DI 容器不可控或需细粒度生命周期）：

var pool = new AsyncResourcePool<HttpClient>(
    ct => Task.FromResult(new HttpClient(new HttpClientHandler { UseCookies = false })),
    client => client.Dispose(),
    maxSize: 5);
// 使用
var client = await pool.RentAsync();
try
{
    var res = await client.GetAsync("https://api.example.com", ct);
    // ...
}
finally
{
    pool.Return(client); // 必须确保执行
}

注意：