1

伙计们，我发现自己处于一个奇怪的境地。我需要将不同返回类型的任务链接在一起。通常，您可以执行以下操作 

Task<T> t = Task<T>.Factory.StartNew(() => ... some T instance);
Task t2 = t.ContinueWith<U>(parent => ...);
return Task.WhenAll(t, t2);

然而，我的复杂之处在于使用FromAsync辅助方法来包装开始/结束对并将其转换为任务。我正在尝试使用 HttpWebRequest 和 .NET 4.0 上的任务编写异步客户端（因此 await 不是一个选项）。

我的问题是返回类型FromAsync是 Task 本身，它阻止我在ContinueWith方法中使用它（ContinueWith期望返回类型并将数据本身包装在一个Task对象中）。

这是我到目前为止的代码，它产生了正确的函数结果，但不是真正的异步： 

public Task<string> GetHttpRequest(string url, string contentType)
{
    var httpWebRequest = CreateHttpWebRequest(url, "GET", contentType);
    Task<WebResponse> httpTask = Task.Factory.FromAsync<WebResponse>(httpWebRequest.BeginGetResponse, httpWebRequest.EndGetResponse, null);

    return httpTask.ContinueWith(httpAntecedent =>
          {
              WebResponse webResponse = httpAntecedent.Result;
              Stream responseStream = webResponse.GetResponseStream();
              byte[] data = new byte[webResponse.ContentLength];

              var streamReadTask = Task<int>.Factory.FromAsync(responseStream.BeginRead, responseStream.EndRead, data, 0, data.Length, TaskCreationOptions.AttachedToParent);

              return streamReadTask.ContinueWith(parent =>
                  {
                      responseStream.Close();
                      webResponse.Close();

                      return Encoding.UTF8.GetString(data);
                  });
          }).Result;
}
4

1 回答 1

3

重新表述你的问题，你有Task<Task<string>>并且你想从中得到Task<string>，而不是同步等待Task完成。

在 C# 5.0 中，您可以使用 double await:来执行此操作return await await task;。

如果没有 C# 5.0，您可以使用Unwrap()，它完全符合您的要求：return task.Unwrap();.

如果出于某种原因，您想自己执行此操作，则可以将ContinueWith()insideContinueWith()与TaskCompletionSource.

但是您的代码有缺陷：它假定您将在一次读取中获得整个响应。这根本无法保证，实际上通常不会正常工作。正确执行此操作将需要更复杂的代码，并且可能还需要TaskCompletionSource.

于 2013-01-21T13:55:10.333 回答