异步事件订阅

Question

我正在使用第三方 API，它看起来像是使用事件驱动架构编写的。我正在对 API 上的一种方法进行异步调用，但该方法的响应仅在事件处理程序中返回。因此我必须订阅事件，然后调用 API 的方法调用。

伪代码示例：

private string myValue;

public async Task<string> TestPost()
{
    // Subscribe to event
    api.OnSomeAPIFunctionResponse += EventHandler1;

    await CallAPIFunction(...with some parameters...);

    return myValue;
}

private void EventHandler1(sender, args)
{
    // This is the value I want to return in the previous function
    myValue = args.value;
}

在上面的代码示例中，当我运行应用程序时，myValue 为 null，因为事件处理程序代码在函数返回执行后启动。

如何让事件处理程序在 TestPost 函数返回之前异步执行。

请建议我在这里可以做什么。

Answer 1

你到底想做什么？您可以通过调用TestPost.Wait() 来获得MYVALUE 的正确值，但这是一个阻塞操作，从UI 线程调用它可能会导致死锁。

如果你想给函数的结果设置一个值，最好await它的结果

var myVar = await TestPost();

这个link 解释了更多关于async/await

编辑：

响应您的评论，您可以使用TaskCompletionSource 来实现您想要的。这是未经测试的代码，但可能是这样的：

    public Task<string> TestPost()
    {
        var tcs = new TaskCompletionSource<string>();
      // Subscribe to event
      api.OnSomeAPIFunctionResponse += ( (s, e) => tcs.SetResult(args.value));

      CallAPIFunction(...with some parameters....);
      return tcs.Task;
    }

然后你以同样的方式得到结果：

var myVar = await TestPost();

TaskCompletionSource 允许您将旧的异步 API 转换为使用基于任务的异步模式。这反过来又允许您使用任务并行库提供的功能，还可以使用 .NET 4.5 async 和 await 中的新关键字。它产生了更简单的代码。您可以在 Parallel .NET 团队的 Stephen Toub 的 this article 中阅读有关 TaskCompletionSource 的更多信息