如何将新的协同路由添加到正在运行的asyncio循环中?即,已经在执行一组协同程序的人.
我想作为一种解决方法,可以等待现有的协同路由完成,然后初始化一个新的循环(使用额外的协同路由).但是有更好的方法吗?
如何将新的协同路由添加到正在运行的asyncio循环中?即,已经在执行一组协同程序的人.
我想作为一种解决方法,可以等待现有的协同路由完成,然后初始化一个新的循环(使用额外的协同路由).但是有更好的方法吗?
您可以使用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()