在同步方法上调用 await 会发生什么？答案

【问题标题】：What happens when await is called on synchronous methods?在同步方法上调用 await 会发生什么？
【发布时间】：2022-03-01 16:35:29
【问题描述】：

我有上传和下载文件的同步方法（以sync_wait方法为代表）。我想以一种永远同时并行执行上传器和下载器的方式异步且无休止地执行此操作。我是这样实现的：

运行此代码：

import time, asyncio
from functools import wraps, partial

# https://stackoverflow.com/a/50450553/3026886
def to_async(func):
    @wraps(func)
    async def run(*args, **kwargs):
        return await asyncio.get_event_loop().run_in_executor(None, partial(func, *args, **kwargs))
    return run

@to_async
def sync_wait(msg):
    time.sleep(msg)

async def producer(n, queue):
    while True:
        msg = .2
        await sync_wait(msg)
        print(f'{n}p')
        await queue.put(msg)

async def consumer(n, queue):
    while True:
        msg = await queue.get()
        print(f'{n}c')
        await sync_wait(msg)

async def main():
    queue = queue = asyncio.Queue(10)
    producers = [producer(n, queue) for n in range(2)]
    consumers = [consumer(n, queue) for n in range(4)]
    await asyncio.gather(*(producers + consumers), return_exceptions=True)

if __name__ == "__main__":
    asyncio.run(main())

打印此输出：

1p
0p
0c
1c
1p
2c
0p
3c
1p
2c
0p
1c
1p
0c
0p
3c
1p
2c
0p
3c
1p
0c
0p
3c
...

这是有道理的，因为我有 2 个生产者和 4 个消费者与我的队列交互。我的老板告诉我我不需要 to_async 装饰器。但是在从sync_wait definiton 中只删除了装饰器之后，我根本没有打印出来。我该如何解释这种新行为？

【问题讨论】：

如果你只删除 sync_wait 而不是await，事情应该会崩溃并出现明显的错误。
我只从sync_wait 中删除了装饰器，这意味着我继续使用sync_wait，但在其定义之上没有@to_async。没有抛出错误

标签： python-asyncio

【解决方案1】：

当你 await 一些无法等待的事情时，事情就会崩溃：

# python3 -m asyncio
asyncio REPL 3.9.9 (main, Jan 10 2022, 11:05:09) 
[Clang 10.0.1 (clang-1001.0.46.4)] on darwin
Use "await" directly instead of "asyncio.run()".
Type "help", "copyright", "credits" or "license" for more information.
>>> import asyncio
>>> await time.sleep(.5)  # sleeps .5 secs before failing to await
Traceback (most recent call last):
...
TypeError: object NoneType can't be used in 'await' expression

但是，如果您将失败的事物放入 Task 或 gather 它们中，它们只会静默失败，直到您真正等待它们检索结果。

>>> async def fail():
...     print("about to fail...")
...     print(1/0)
...
>>> t = asyncio.create_task(fail())
about to fail...
>>> await t  # only fails noticeably when retrieving result
Traceback (most recent call last):
...
ZeroDivisionError: division by zero

因此，如果您将失败的任务放入具有无限运行的非失败任务的 gather(..., return_exceptions=True)，则永远不会报告失败。

【讨论】：