asynchronous - 有没有办法异步处理多个 xml 提要？

Question

我正在使用 Atom10FeedFormatter 类来处理调用 OData Rest API 端点的 atom xml 提要。

它工作正常，但如果提要中有超过 200 个条目，api 给出的结果很慢。

这就是我使用的：

        Atom10FeedFormatter formatter = new Atom10FeedFormatter();

        XNamespace d = "http://schemas.microsoft.com/ado/2007/08/dataservices";

        string odataurl= "http://{mysite}/_api/ProjectData/Projects";

        using (XmlReader reader = XmlReader.Create(odataurl))
        {
             formatter.ReadFrom(reader);
        }

         foreach (SyndicationItem item in formatter.Feed.Items)
         {
              //processing the result
         }

我想通过拆分原始请求以查询跳过一些条目并限制条目大小的结果来加快这个过程至少快一点。

主要思想是使用 $count 统计 feed 的数量，将 feed 结果分成 20 个块，使用端点 url 中的 $skip 和 $top，遍历结果，最后汇总。

int countoffeeds = 500; // for the sake of simplicity, of course, i get it from the odataurl using $count
int numberofblocks = (countoffeeds/20) + 1;

for(int i = 0; i++; i<numberofblocks){
    int skip = i*20;
    int top = 20;
    string odataurl = "http://{mysite}/_api/ProjectData/Projects"+"?&$skip="+skip+"&top=20";
    Atom10FeedFormatter formatter = new Atom10FeedFormatter();


    using (XmlReader reader = XmlReader.Create(odataurl))
    {
         formatter.ReadFrom(reader); // And this the part where I am stuck. It returns a void so I 
                                     //cannot use Task<void> and process the result later with await 
    }
...

通常我会使用对 api 的异步调用（这种情况下 numberofblocks = 26 个并行调用），但我不知道该怎么做。formatter.ReadFrom返回 void，因此我不能将它与 Task 一起使用。

我该如何解决这个问题，以及如何同时读取多个 xml 提要？

标签： asynchronoustaskodataxmlreaderatom-feed

Answer 1

通常我会使用对 api 的异步调用（这种情况下 numberofblocks = 26 个并行调用），但我不知道该怎么做。formatter.ReadFrom 返回 void，因此我不能将它与 Task 一起使用。

Atom10FeedFormatter在这一点上是一个非常过时的类型，它不支持异步。它也不太可能被更新以支持异步。

我该如何解决这个问题，以及如何同时读取多个 xml 提要？

由于您被困在同步世界中，因此您可以选择使用“假异步”。这只是意味着您将在线程池线程上执行同步阻塞工作，并将这些操作中的每一个视为异步操作。IE：

var tasks = new List<Task<Atom10FeedFormatter>>();
for(int i = 0; i++; i<numberofblocks) {
  int skip = i*20;
  int top = 20;
  tasks.Add(Task.Run(() =>
  {
    string odataurl = "http://{mysite}/_api/ProjectData/Projects"+"?&$skip="+skip+"&top=20";
    Atom10FeedFormatter formatter = new Atom10FeedFormatter();
    using (XmlReader reader = XmlReader.Create(odataurl))
    {
      formatter.ReadFrom(reader);
      return formatter;
    }
  }));
}
var formatters = await Task.WhenAll(tasks);