为啥大多数 asyncio 示例都使用 loop.run_until_complete()？

Posted 2023-03-30

【中文标题】为啥大多数 asyncio 示例都使用 loop.run_until_complete()？

【英文标题】：Why do most asyncio examples use loop.run_until_complete()?为什么大多数 asyncio 示例都使用 loop.run_until_complete()？

【发布时间】：2016-10-19 23:46:46

【问题描述】：

我正在浏览 asyncio 的 Python 文档，我想知道为什么大多数示例使用 loop.run_until_complete() 而不是 Asyncio.ensure_future()。

例如：https://docs.python.org/dev/library/asyncio-task.html

看来ensure_future 会是一个更好的方式来展示非阻塞函数的优势。另一方面，run_until_complete 像同步函数一样阻塞循环。

这让我觉得我应该使用 run_until_complete 而不是 ensure_future 和 loop.run_forever() 的组合来同时运行多个协同程序。

【问题讨论】：

run_until_complete 不会阻止任何内容。它与run_forever 的区别在于循环在协程完成时暂停。唯一会阻塞的情况是你的协程从不等待。

我写了这个pastebin.com/Qi8dQ3bh，但它似乎确实阻止了循环。 do_other_things() 直到 do_io() 完成后才会执行，即使 do_io() 等待睡眠。

那是因为循环中没有安排其他任何事情。在拨打run_forever 之前尝试拨打loop.create_task(do_other_things())。

【参考方案1】：

run_until_complete 用于运行未来直到它完成。它将阻止其后代码的执行。但是，它确实会导致事件循环运行。任何已安排好的未来都将运行，直到传递给run_until_complete 的未来完成。

举个例子：

import asyncio

async def do_io():
    print('io start')
    await asyncio.sleep(5)
    print('io end')

async def do_other_things():
    print('doing other things')

loop = asyncio.get_event_loop()

loop.run_until_complete(do_io())
loop.run_until_complete(do_other_things())

loop.close()

do_io 将运行。完成后，do_other_things 将运行。您的输出将是：

io start
io end
doing other things

如果您在运行do_io 之前将do_other_things 与事件循环一起安排，则当前者等待时，控制将从do_io 切换到do_other_things。

loop.create_task(do_other_things())
loop.run_until_complete(do_io())

这将为您提供以下输出：

doing other things
io start
io end

这是因为do_other_things 是在do_io 之前安排的。有很多不同的方法可以获得相同的输出，但哪种方法真正有意义取决于您的应用程序实际执行的操作。所以我将把它作为练习留给读者。

【讨论】：

您知道为什么我在运行您的代码时收到错误“RuntimeError: This event loop is already running”吗？

@Patrick 您是否尝试从函数内部调用loop.run_until_complete？

我意识到问题可能出在 Jupyter 上。它适用于 python 代码。

【参考方案2】：

我想大多数人都不理解create_task。 当你create_task 或ensure_future 时，它已经被安排好了。

async def say_after(delay, what):
    await asyncio.sleep(delay)
    print(what)

async def main():
    task1 = asyncio.create_task(
        say_after(1, 'hello')) # not block here

    task2 = asyncio.create_task(
        say_after(2, 'world'))

    print(f"started at time.strftime('%X')") # time0

    await task1 # block here!

    print(f"finished at time.strftime('%X')") 
    
    await task2 # block here!

    print(f"finished at time.strftime('%X')")

asyncio.run(main())

结果是

time0 
print hello 
time0+1 
print world 
time0+2

但如果您不等待任务1，请执行其他操作

async def main():
    task1 = asyncio.create_task(
        say_after(1, 'hello')) # not block here
    print(f"finished at time.strftime('%X')") # time0
    await asyncio.sleep(2) # not await task1
    print(f"finished at time.strftime('%X')") # time0+2
 

asyncio.run(main())

它会做task1 STILL

time0
print hello
time0+2