当我需要等待事件时如何使方法异步

Question

我做了一个这样的函数：

public void GetData(string dataToPost)
{
    var url = "some URL";

    using (var client = new WebClient())
    {
        client.Headers[HttpRequestHeader.ContentType] = "application/json";

        client.UploadStringCompleted += (s, e) =>
            {
                Console.WriteLine("Result is here");
                Console.WriteLine(e.Result);
            };

        client.UploadStringAsync(new System.Uri(url), "POST", dataToPost);
    }
}

这里的问题是我想要从服务器返回一个值（HTTP 响应）。

我希望我的函数是异步的，因此例如我希望能够在一个循环中调用它 5 次，而无需等待每次调用在下一次调用之前返回某些内容。

我不知道如何实现它。我试图创建一些 Task 对象来等待它，但是 Task 需要一个委托，我不知道我可以给它什么委托。

上面的 Te 函数使用了一个事件，该事件在结果到来时被触发 - 所以我需要返回该结果。

我该怎么做？

Answer 1

WebClient 有一个返回 Task<string> 的重载：

https://msdn.microsoft.com/en-us/library/hh193920(v=vs.110).aspx

您可以触发所有请求，然后使用Task.WhenAll 等待它们：

public void GetData(string dataToPost)
{
    var url = "some URL";
    var url2 = "some other URL";

    using (var client = new WebClient())
    {
        client.Headers[HttpRequestHeader.ContentType] = "application/json";

        var task1 = client.UploadStringTaskAsync(new System.Uri(url), "POST", dataToPost);
        var task2 = client.UploadStringTaskAsync(new System.Uri(url2), "POST", dataToPost);

        var results = Task.WhenAll(task1, task2).Result;

        foreach (var result in results)
        {
            Console.WriteLine("Result is here");
            Console.WriteLine(result);
        }
    }
}

如果您可以将 GetData 更改为 async 方法，那就更好了，您可以在 Task.WhenAll 上使用 await

Answer 2

正如在 cmets 中已经说过的，HttpClient 是此类任务更自然的选择。但是，您仍然可能想知道如何提供订阅事件的任务，这可以通过 TaskCompletionSource<T> 完成，只需对您的代码进行非常小的更改：

private Task<string> GetData(string dataToPost)
{
    var url = "some URL";
    var resultSource = new TaskCompletionSource<string>();

    using (var client = new WebClient())
    {
        client.Headers[HttpRequestHeader.ContentType] = "application/json";

        client.UploadStringCompleted += (s, e) => {
            Console.WriteLine("Result is here");
            Console.WriteLine(e.Result);

            // this will complete the task
            resultSource.SetResult(e.Result);
        };

        client.UploadStringAsync(new System.Uri(url), "POST", dataToPost);
    }

    return resultSource.Task;
}

在这种情况下，您还可以设置cancellation（也可以使用given token）和exception（即使使用multiple exceptions），这样它自然会满足您的需求。对于并发事件订阅的情况，这三种方法都可以Try*方式完成。

还要注意@Stefanod'Antonio' 对async method 过载的回答。