.net - 将重要代码转换为新的 .NET 异步模式 - 如何处理产量循环

Question

我正在编写一个库来使用 Azure 表存储。基本模式是给定的 HTTP 请求在内容流中返回一个数字结果，并在 header 中返回一个指向下一组结果的指针。当结果是从流中读取时，它们就被产生了。我正在使用 System.Net.Http 库(以前是 Microsoft.Net.Http)，它在最新版本中删除了同步版本的 HttpClient.Send 和其他同步方法。新版本使用任务。我以前使用过 Tasks，但没有用于这么复杂的事情，而且我很难开始。

已转换为异步模式的调用是:HttpClient.Send、response.Context.ContentReadSteam。我已经清理了代码，以便显示重要的部分。

var queryUri = _GetTableQueryUri(tableServiceUri, tableName, query, null, null, timeout);
while(true) {
    var continuationParitionKey = "";
    var continuationRowKey = "";
    using (var request = GetRequest(queryUri, null, action.Method, azureAccountName, azureAccountKey))
    {
        using (var client = new HttpClient())
        {
            using (var response = client.Send(request, HttpCompletionOption.ResponseHeadersRead))
            {
                continuationParitionKey = // stuff from headers
                continuationRowKey = // stuff from headers

                using (var reader = XmlReader.Create(response.Content.ContentReadStream))
                {
                    while (reader.Read())
                    {
                        if (reader.NodeType == XmlNodeType.Element && reader.Name == "entry" && reader.NamespaceURI == "http://www.w3.org/2005/Atom")
                        {
                            yield return XElement.ReadFrom(reader) as XElement;
                        }
                    }
                    reader.Close();
                }
            }
        }
    }
    if (continuationParitionKey == null && continuationRowKey == null)
        break;

    queryUri = _GetTableQueryUri(tableServiceUri, tableName, query, continuationParitionKey, continuationRowKey, timeout);
}

我已成功转换的示例如下。

client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead).ContinueWith(task =>
    {
        using (var response = task.Result)
        {
            if (response.StatusCode == HttpStatusCode.Created && action == HttpMethod.Post)
            {
                return XElement.Load(response.Content.ReadAsStreamAsync().Result);
            }
        }
    });

有没有人对如何将循环/产量转换为新模式有任何建议？

谢谢!
埃里克

Answer 1

正如您所发现的，async使用 yield 效果不佳马上。尽管它们进行了类似的代码转换，但目标却大不相同。

有两种解决方案:一种是提供缓冲区并使用生产者/消费者类型的方法。 System.Tasks.Dataflow.dll对于管理复杂代码中的缓冲区很有用。

另一种解决方案是编写一个“异步枚举器”。这在概念上更接近您的代码应该做什么，但此解决方案比生产者/消费者解决方案复杂得多。

“异步枚举器”类型在 this video on Rx 中有一点讨论，您可以从 an experimental Rx package 下载它(请注意，尽管这是由 Rx 团队完成的，但它实际上并不使用 Rx)。