如何将协程添加到正在运行的异步循环? [英] how to add a coroutine to a running asyncio loop?

问题描述

如何将新的协程添加到正在运行的asyncio循环中? IE.已经执行了一组协程的人.

How can one add a new coroutine to a running asyncio loop? Ie. one that is already executing a set of coroutines.

我想作为一种解决方法，可以等待现有的协程完成，然后初始化一个新的循环(使用附加的协程).但是有更好的方法吗?

I guess as a workaround one could wait for existing coroutines to complete and then initialize a new loop (with the additional coroutine). But is there a better way?

推荐答案

您可以使用

You can use create_task for scheduling new coroutines:

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()

这篇关于如何将协程添加到正在运行的异步循环?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！