在事件处理程序上使用 lambda exp 时如何等待多个任务

Question

我有 2 个类 Main.cs 和 Processing.cs（简称 P 和 M）类 M 通过一个 html 链接调用 P，P 在 tern 下载，转换为 Base64，重命名并保存文件，然后返回一个字符串回到 M，现在我需要 M 等到所有这些都完成才能继续，但我一直没能。

我在事件处理程序中使用了 lambda 表达式，以便能够在该函数中执行所有操作，而不是为事件触发器使用单独的函数，因此我可以使用 Base64 转换文件返回字符串，但它只是返回空字符串，不要等到它被分配。

我认为 taskA.Wait() 调用会使其等待所有处理完成，但事实并非如此

如果有人有任何想法，我将不胜感激。

来自 Main.cs 的调用是这样的：

Processing processing = new processing();
String _link = “http://www.something.com”;
var ResultBase64_Val = processing.FileToBase64(_link).Result;

在 Processing.cs 中的函数是：

public async Task<String> FileToBase64(String filePath)
{
    String convertedFile = "";

    WebClient client = new WebClient();
    Task taskA = Task.Factory.StartNew(() => client.OpenReadCompleted += async (object sender, OpenReadCompletedEventArgs e) =>
     {   
           byte[] buffer = new byte[e.Result.Length];
           buffer = new byte[e.Result.Length];
           await e.Result.ReadAsync(buffer, 0, buffer.Length);
           convertedFile = Convert.ToBase64String(buffer);
     });
     client.OpenReadAsync(new Uri(filePath));
     taskA.Wait();

     return convertedFile;           
    }

谢谢， 鲍勃

Answer 1

您的代码的问题在于，以Task.Factory.StartNew 开始的任务会立即完成，远在OpenReadCompleted 将来某个时间被触发之前。也就是说，用Task.Run 或Task.Factory.StartNew 包装像OpenReadAsync 这样的自然异步API 无论如何都是一个坏主意。即使您以某种方式等待事件，或者使用同步OpenRead，您也会浪费一个池线程。

为此有新的WebClient.OpenReadTaskAsync 方法：

public async Task<String> FileToBase64(String filePath)
{
    using (var client = new WebClient())
    using (var stream = await client.OpenReadTaskAsync(new Uri(filePath)))
    {
        // use stream.ReadAsync
    }
}

我也推荐HttpClient而不是WebClient，前者支持多个HTTP请求并行：

using System.Net.Http;

// ...

public async Task<String> FileToBase64(String filePath)
{
    using (var client = new HttpClient())
    using (var response = await client.GetAsync(filePath))
    using (var stream = await response.Content.ReadAsStreamAsync())
    {
        return string.Empty;
        // use stream.ReadAsync
    }
}

Answer 2

如果你想使用 WebClient，并且你想从方法中返回结果，你需要使用 TaskCompletionSource 并正常订阅事件

public Task<String> FileToBase64(String filePath)
{
    TaskCompletionSource<string> completion = new TaskCompletionSource<string>();
    String convertedFile = "";

    WebClient client = new WebClient();
    client.OpenReadCompleted += (s, e) =>
    {
        TextReader reader = new StreamReader(e.Result);
        string result = reader.ReadToEnd();
        completion.SetResult(result);
    };
    client.OpenReadAsync(new Uri(filePath));

    return completion.Task;
}

鉴于此答案，我建议使用 HttpClient 而不是 WebClient

Answer 3

Noseratio answer 和 Shawn Kendrot answer 都应该可以工作。但我会尝试使用其他方法 - WebRequest。

首先，我必须将我的 WebRequest 方法扩展为 GetRequestStreamAsync() - WP 缺少此方法：

public static class Extensions
{
  public static Task<Stream> GetRequestStreamAsync(this WebRequest webRequest)
  {
    TaskCompletionSource<Stream> taskComplete = new TaskCompletionSource<Stream>();
    webRequest.BeginGetRequestStream(arg =>
    {
        try
        {
            Stream requestStream = webRequest.EndGetRequestStream(arg);
            taskComplete.TrySetResult(requestStream);
        }
        catch (Exception ex) { taskComplete.SetException(ex); }
    }, webRequest);
    return taskComplete.Task;
  }
}

然后我会把你的任务转换成这样的：

public async Task<string> FileToBase64(string filePath)
{
    try
    {
       WebRequest request = WebRequest.Create(new Uri(filePath));
       if (request != null)
       {
           using (Stream resopnse = await request.GetRequestStreamAsync())
           using (MemoryStream temp = new MemoryStream())
           {
               const int BUFFER_SIZE = 1024;
               byte[] buf = new byte[BUFFER_SIZE];

               int bytesread = 0;
               while ((bytesread = await resopnse.ReadAsync(buf, 0, BUFFER_SIZE)) > 0)
                     temp.Write(buf, 0, bytesread);

               return Convert.ToBase64String(temp.ToArray());
            }
        }
        return String.Empty;
   }
   catch { return String.Empty; }
}

也许这会有所帮助。

Answer 4

首先，不要将Task.Factory.StartNew 与async 方法一起使用。 Stephen Toub 和 Stephen Clearly 已经解释了原因。

其次，如果您使用的是async-await，那么您可以将WebClient class 的~TaskAsync 方法与Microsoft Async NuGet package 结合使用——假设您说它是用于Windows电话 8。

附带说明，您应该始终使用 Async（如果不可能，则使用 TaskAsync）为您的异步方法添加后缀。

鉴于此，您的代码变为：

public async Task<String> FileToBase64Async(String filePath)
{
    String convertedFile = "";

    var client = new WebClient();

    Task taskA = Task.Factory.StartNew(() => client.OpenReadCompleted += async (object sender, OpenReadCompletedEventArgs e) =>
    {
        var buffer = await webclient.DownloadDataTaskAsync(filePath);
        convertedFile = Convert.ToBase64String(buffer);

        return convertedFile;           
    }
}

但是您可以在Microsoft HTTP Client Libraries NuGet package 上找到新的HttpClient class，为您提供更好的服务。

最后，你should not block on async code in the UI thread。