并发调用的 C# 异步方法应等待第一个操作完成

Question

我有一个看起来像的方法

public async Task<OpenResult> openAsync()

我想做一些事情，比如如果在执行过程中当前有对 openAsync 的调用，我想将对 OpenAsync 的任何调用添加到队列中。

当第一个调用完成时，我想用第一个调用的结果完成队列中的所有。

在C#中有什么方法可以实现

Answer 1

通常，这种细节留给调用者，即通过让调用者适本地await并且只在它们应该时调用方法调用方法。但是，如果您必须这样做，一种简单的方法是通过信号量；考虑:

class HazProtected
{
    private readonly SemaphoreSlim _lock = new SemaphoreSlim(1, 1);

    public async Task<OpenResult> OpenAsync(CancellationToken cancellationToken = default)
    {
        await _lock.WaitAsync(cancellationToken);
        try
        {
            return await DoOpenAsync(cancellationToken);
        }
        finally
        {
            _lock.Release();
        }
    }

    private async Task<OpenResult> DoOpenAsync(CancellationToken cancellationToken)
    {
        // ... your real code here
    }
}

OpenAsync 中的代码确保一次只能有一个并发异步调用者尝试打开它。当发生冲突时，调用者将被异步保留，直到可以获取信号量。但是，有一个复杂的问题； SempahoreSlim 在 .NET Framework 上存在一些已知问题(已在 .NET Core 中解决)同时存在异步 和 同步信号量获取 - which can lead to a spiral of death .

---

在更复杂的场景中，可以编写自己的待处理调用者队列；这是一个非常非常奇特的场景，通常不应该尝试，除非您确切地理解为什么要这样做!