Asyncio: keep multiple coroutines running

Question

I have multiple coroutines which need to be running (forever) at the same time. For error handling one of the routines occasionally ends and needs to be respawned and I use the following code, which however assumes that it is coroutine1 that needs restarting.

pending = {coroutine1(), coroutine2()}
while True:
    a = asyncio.wait(pending, return_when=asyncio.FIRST_COMPLETED)
    done, pending = loop.run_until_complete(a)
    pending = pending | {coroutine1()}

How can I solve this in a better and more general way?

Vincent · Accepted Answer · 2017-04-07 13:58:10Z

1

What about using a different approach?

async def run_forever(corofn):
    while True:
        await corofn()

corofns = coroutine1, coroutine2
await asyncio.wait(map(run_forever, corofns))

answered Apr 7, 2017 at 13:58

Vincent

13.5k1 gold badge51 silver badges68 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Asyncio: keep multiple coroutines running

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related