2

我有以下扩展方法用于对 WebRequest 对象使用异步调用。

 public static Task<WebResponse> GetReponseAsync(this WebRequest request)
    {
        return Task.Factory.FromAsync<WebResponse>(request.BeginGetResponse, request.EndGetResponse, null);
    }

    public static Task<Stream> GetRequestStreamAsync(this WebRequest request)
    {
        return Task.Factory.FromAsync<Stream>(request.BeginGetRequestStream, request.EndGetRequestStream, null);
    }

我想使用这些扩展方法将以下代码转换为异步等效代码。

using (Stream rs = request.GetRequestStream())
{
   var postData = Encoding.ASCII.GetBytes(PostData);
   rs.Write(postData, 0, postData.Length);

   using (WebResponse response = request.GetResponse())
   using (StreamReader reader = new StreamReader(response.GetResponseStream()))
   {
       str = reader.ReadToEnd();

       rs.Close();
       reader.Close();
       response.Close();
   }
}

我使用另一段使用 WebRequest 的代码轻松地做到了这一点，但这不需要第一次调用 GetRequestStream()。

request.GetReponseAsync().ContinueWith(t =>
{
    if (t.Exception == null)
    {
        using (var sr = new StreamReader(t.Result.GetResponseStream()))
        {
            str = sr.ReadToEnd();
        }
    }
});

如何转换第一个代码块以使用我的扩展方法并等效？

编辑我正在使用 .NET 4.0，所以 async/await 目前不是一个选项。

4

1 回答 1

3

你只需要链接ContinueWith调用。根据经验，序列中的每个异步操作都会有一个 ContinueWith。每个 ContinueWith 通常以结束，return <some async call>下一个将开始处理其结果。

request.GetRequestStreamAsync()
       .ContinueWith((trs) =>
           {
               var postData = System.Text.Encoding.ASCII.GetBytes("dummy");
               trs.Result.Write(postData, 0, postData.Length);
               return request.GetResponseAsync();
           }).Unwrap()
       .ContinueWith((resp) =>
           {
               using (var sr = new StreamReader(resp.Result.GetResponseStream()))
               {
                   var str = sr.ReadToEnd();
               }
           });

请注意，在我的代码（以及您的异步版本）中，并非所有对象都像在原始代码中那样被释放。

在每个步骤中，您可能想要检查 Status 或 IsFaulted/IsCanceled 属性，或者使用带有 TaskContinuationOptions 参数的 ContinueWith 重载。对于后一个选项，请注意前一个任务未以与选项匹配的方式完成会导致任务被取消。如果您需要传递错误，则该方法不会。就我个人而言，我将所有检查包装到一个方法中，该方法要么通过错误和取消，要么在成功完成时运行委托。否则，你很快就会得到大量的样板检查代码。

于 2013-07-16T05:28:48.120 回答