.net 信号量的多线程问题

正如 comments 中所讨论的，这里有几个比赛条件.

1. 线程1持有锁，线程2等待WaitAsync().线程1释放锁，然后判断semaphore.CurrentCount，然后线程2才能获取锁.
2. 线程1持有锁，释放锁，并判断通过的semaphore.CurrentCount个.线程2进入GetValueWithBlockAsync，调用Semaphores.GetOrAdd并获取信号量.线程1然后调用Semaphores.TryRemove并使信号量双工.

你真的需要锁定从Semaphores中删除一个条目的决定——这是不可能的.您也无法跟踪是否有线程从Semaphores获取了信号量(或者正在等待，或者尚未到达该点).

一种方法是这样做:在每个人之间共享一个锁，但只有在获取/创建信号量并决定是否处理它时才需要它.我们手动跟踪当前有多少线程对特定信号量感兴趣.当一个线程释放了信号量后，它会获取共享锁，以判断当前是否有其他人对该信号量感兴趣，并且只有在没有其他人感兴趣时才会处理该信号量.

private static readonly object semaphoresLock = new();
private static readonly Dictionary<string, State> semaphores = new();

private async Task<TModel> GetValueWithBlockAsync<TModel>(string valueKey, Func<Task<TModel>> valueAction)
{
    State state;
    lock (semaphoresLock)
    {
        if (!semaphores.TryGetValue(valueKey, out state))
        {
            state = new();
            semaphores[valueKey] = state;
        }
        
        state.Count++;
    }

    try
    {
        await state.Semaphore.WaitAsync();

        return await valueAction();
    }
    finally
    {
        state.Semaphore.Release();
        lock (semaphoresLock)
        {
            state.Count--;
            if (state.Count == 0)
            {
                semaphores.Remove(valueKey);
                state.Semaphore.Dispose();
            }
        }
    }
}

private class State
{
    public int Count { get; set; }
    public SemaphoreSlim Semaphore { get; } = new(1, 1);
}

当然，另一个 Select 是让Semaphores人成长.也许你有一个周期性的操作来判断并清除任何没有被使用的东西，但是这当然需要得到保护，以确保线程不会突然对正在被清除的信号量感兴趣.