作为异步函数调用的结果返回 IEnumerable

Question

我有一个获取一系列项目的函数：

List<MyType> GetPage(int pageNr) {...}

要获取所有可用项目，您可以执行以下操作：

IEnumerable<MyType> FetchMyItems()
{
    int pageNr = 0;
    var fetchedItems = GetPage(pageNr);
    while (fetchedItems.Any()
    {   // there are items to return
        // yield return the fetched items: 
        foreach (var fetchedItem in fetchedItems)
            yield return fetchedItems;

        // get the next page
         ++pageNr;
         fetchedItems = GetPage(pageNr)
    }
}

使用此方法，我的用户将不再需要获取每页的项目，如果他们只需要几个项目，则只会获取第一页。当他们需要更多项目时，将自动获取更多页面。缺点当然是我有时会多取一些不会用到的物品。

我想要一个异步版本

所以我有以下GetPage：

async Task<List<MyType>> GetPageAsync(int pageNr) {...}

根据我对 IEnumerable 的了解，它不会创建结果序列，它只会创建枚举此序列的可能性。

这种枚举是使用 'foreach' 显式完成的，或隐式使用 'ToList'、'ToArray' 等 LINQ 函数，但也使用 'FirstOrDefault'、'Any'、Sum 等函数。

var fetchItemTasks = FetchMyItemsAsync();
foreach (var fetchItemTask in fetchedItemTasks)
{
      MyType fetchedItem = await fetchItemTask;
      Process(fetchedItem);
}

或者如果你做这个低级：

var myitemsEnumerable = fetchMyItemsAsync();
// don't await yet, only create the possibility to enumerate

var enumerator = myItemsEnumerable.GetEnumerator();
while (enumerator.MoveNext())
{   // there is an item available in current:
    Task<MyType> task = enumerator.Current;
    return task;
}

看这个，看来这个函数不应该返回Task<IEnumerable<MyType>>而是IEnumerable<Task<MyType>>，如果你想访问一个元素你必须等待这个。

因此，返回枚举等待项的可能性的函数本身并不是异步的。您无需等待可枚举，无需访问慢速提供程序（如数据库）即可创建此可枚举。可枚举序列中的项是可等待的：

IEnumerable<Task<MyType>> FetchMyItems()
{
    int pageNr = 0;
    Task<List<MyType>> fetchItemTask = GetPageAsync(pageNr);

现在呢？如果我await fetchItemTask，这些项目已经是本地的，没有什么可以等待的了。如果我fetchItemTask.Wait()，功能块。

Answer 1

您对 async/await 模式的实现看起来不正确。

GetPageAsync签名没问题：

async Task<List<MyType>> GetPageAsync(int pageNr) {...}

现在，如果你想异步调用这个方法，你必须使用await关键字，它会暂停执行方法并将控制权返回给它的调用者，直到GetPageAsync结果准备好：

List<MyType> items = await GetPageAsync(pageNr);

或

Task<List<MyType>> getPageTask = GetPageAsync(pageNr);

// Some other stuff

List<MyType> items = await getPageTask;

但请注意，await 关键字只能在本身为 async 的方法内使用。

可能我没有意识到您的应用程序异步模型的全部想法，但无论如何，我建议您先看看这个MSDN article on asynchronous programming with async/await。