python - 如何将协程添加到正在运行的 asyncio 循环中？

Question

如何将新的协程添加到正在运行的 asyncio 循环中？ IE。一个已经在执行一组协程的程序。

我想作为一种解决方法，可以等待现有协程完成，然后初始化一个新循环(使用额外的协程)。但是有没有更好的方法？

Answer 1

您可以使用 create_task用于调度新的协程:

import asyncio

async def cor1():
    ...

async def cor2():
    ...

async def main(loop):
    await asyncio.sleep(0)
    t1 = loop.create_task(cor1())
    await cor2()
    await t1

loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()