等待在异步方法中调用回调[重复]

Question

假设我有以下订阅事件的方法。事件发生时调用回调。我想阻止我的方法返回，直到调用回调，或者经过 10 秒。

public async Task<string> GetImportantString()
{
    string importantResult = null;
    await SubscribeToEvent("some event", async (message) =>
    {
        importantResult = message; // When "some event" happens, callback is called and we can set importantResult 
    }

    return message; // Only return when the callback is called, or 10 seconds have passed
}

SubscribeToEvent()的签名如下：

public Task SubscribeToEvent(string event, Action<string> handler);

我使用方法GetImportantString()的方式如下：

public void SomeMethod() 
{
    // Do some things
    var importantString = await GetImportantString();
   // Do other things
}

问题是在调用回调之前我找不到不从GetImportantString() 返回的方法。理想情况下，我想等到回调调用最多 10 秒，如果在 10 秒内未调用回调，则返回错误。如何在调用回调之前暂停GetImportantString() 的执行？

Answer 1

看看这个：

public async Task<string> GetImportantString()
{
    string importantResult = null;
    using (var sph = new SemaphoreSlim(0, 1))
    {
        await SubscribeToEvent("some event", async (message) =>
        {
            importantResult = message; // When "some event" happens, callback is called and we can set importantResult 
            sph.Release();
        });

        var t = sph.WaitAsync();

        if (await Task.WhenAny(t, Task.Delay(10000)) == t)
        {
            return importantResult;
        }
    }
    throw new TimeoutException(); // whatever you want to do here
}

我们使用SemaphoreSlim 在字符串设置时发出信号。

此时，我们在 Task.WhenAny 上等待，它让我们知道信号量何时释放或延迟任务过去。如果 Semaphore 释放，我们可以安全地假设字符串已设置并返回。