python - 为什么在使用带有 asyncio 的协程的列表推导式时会得到不同的结果?

标签 python python-asyncio

我最初有一些代码将结果聚合到一个列表中。当我重构此代码以使用列表综合时,我得到了意想不到的结果:

import asyncio

@asyncio.coroutine
def coro():
    return "foo"


# Writing the code without a list comp works,
# even with an asyncio.sleep(0.1).
@asyncio.coroutine
def good():
    yield from asyncio.sleep(0.1)
    result = []
    for i in range(3):
        current = yield from coro()
        result.append(current)
    return result


# Using a list comp without an async.sleep(0.1)
# works.
@asyncio.coroutine
def still_good():
    return [(yield from coro()) for i in range(3)]


# Using a list comp along with an asyncio.sleep(0.1)
# does _not_ work.
@asyncio.coroutine
def huh():
    yield from asyncio.sleep(0.1)
    return [(yield from coro()) for i in range(3)]


loop = asyncio.get_event_loop()
print(loop.run_until_complete(good()))
print(loop.run_until_complete(still_good()))
print(loop.run_until_complete(huh()))

如果我运行这段代码,我会得到这样的输出:

$ python3.4 /tmp/test.py
['foo', 'foo', 'foo']
['foo', 'foo', 'foo']
<generator object <listcomp> at 0x104eb1360>

为什么第三个 huh() 函数会得到不同的结果?

最佳答案

解决您的问题的方法是在第三个函数的返回中放置 next(...) 而不是 ... ,或者更好地编写 return list((yield from coro()) for i in range(3))(这个想法归功于@zch),或者最好继续使用第一个函数。


重点是第二个函数不是生成器。它只是一个返回理解生成器的普通函数。

例如这段代码在生成器之外是有效的:

values = [(yield x) for x in range(3)]

然后你可以这样做:

next(values)
0
next(values)
1
next(values)
2
next(values)
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
StopIteration: [None, None, None]

Decorator @coroutine 然后通过迭代结果使第二个函数成为生成器,参见 here , 第 143 行。

相比之下,第一个和第三个函数实际上是生成器,@coroutine 装饰器只是返回它们自己,参见 here ,第 136-137 行。在第一种情况下,生成器返回列表(实际上引发 StopIteration(['foo', 'foo', 'foo']))。在第三种情况下,它返回理解生成器。

关于python - 为什么在使用带有 asyncio 的协程的列表推导式时会得到不同的结果?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29334054/

相关文章:

python - 枚举函数

python - 如何在Python上过滤数据透视表

python - 将字符串列表转换为数字列表 Python

python - 如何使用 pptx-python 库更改标题位置?

python - 当没有收到任何消息时如何停止阅读

python - Pandas 数据框循环

python - 有没有办法使用纯 python 为纯函数释放 GIL?

python - aiohttp:按域限制每秒请求数

python - 安排异步任务每 X 秒执行一次?

python-3.x - 如何使用带有 asyncio 的高速公路连接到 binance websocket 服务