`AsyncIterable[T]` 和 `Iterable[Awaitable[T]]` 之间的区别？答案

【问题标题】：Difference between `AsyncIterable[T]` and `Iterable[Awaitable[T]]`?`AsyncIterable[T]` 和 `Iterable[Awaitable[T]]` 之间的区别？
【发布时间】：2021-04-09 08:09:10
【问题描述】：

取以下两个函数：

import asyncio

def a():
    for index in range(2):
        # Capture `index` as `local_index` in case awaiting is postponed.
        async def next_index(local_index=index):
            # Simulate network request.
            await asyncio.sleep(0)

            return local_index

        yield next_index()

async def b():
    for index in range(2):
        # Simulate network request.
        await asyncio.sleep(0)

        yield index

a 返回一个Iterable[Awaitable[int]]。 b 返回一个 AsyncIterable[int]。两者的迭代都可以这样完成：

async def main():
    for index in a():
        print(await index)

    async for index in b():
        print(index)

asyncio.run(main())

输出：

上述示例的关键是我能够在没有外部 async 的情况下生成 Awaitables，因为内部函数是 async。

就功能而言，AsyncIterable[T] 是否允许 Iterable[Awaitable[T]] 提供任何功能？

我还有一个非常相关的问题。来自PEP 492 - Asynchronous Iterators and "async for"：

异步迭代器对象必须实现 anext 方法（或者，如果使用 CPython C API 定义，则为 tp_as_async.am_anext 插槽）返回一个可等待的。

由于不需要外部async 来产生Awaitables，__anext__ 是否提供优于同步__next__ 返回Awaitables 的专有功能？

这可能是我遗漏的地方，但根据我目前的理解，异步协议和StopAsyncIteration 看起来可以使用同步协议和StopIteration 来模仿它们（当然不那么简洁）。

【问题讨论】：

标签： python asynchronous async-await generator python-asyncio

【解决方案1】：

您缺少的一个大问题是如何处理循环结束。

异步迭代器的__anext__ 返回一个可等待的对象，它可以挂起、使用值引发StopIteration 以生成下一个元素，或者引发StopAsyncIteration 以发出循环结束的信号。（PEP 说“要停止迭代 __anext__ 必须引发 StopAsyncIteration 异常。”，但 StopAsyncIteration 异常确实发生在等待可等待对象时，而不是在调用 __anext__ 时同步发生。）

相比之下，如果您尝试使用可等待元素创建常规可迭代对象，则迭代器的 __next__ 需要引发 StopIteration 以结束循环。

这意味着__next__ 在它知道是否会有另一个元素之前不能返回。 __next__ 是同步的，所以当它解决这个问题时，控制不能返回到事件循环。这意味着您可能会浪费大量时间同步等待网络流量或其他所有工作都停滞不前。

你可以通过更多的手动处理来解决这个问题，但是它在两端都变得非常尴尬，尤其是迭代器的一端，你需要某种等效的 StopAsyncIteration 来消除“这是下一个元素”与“循环完成”的歧义.

【讨论】：