Feature or enhancement

Proposal:

Currently consuming items from a queue is very complex. You need to

1. use an infinite while loop
2. call queue.task_done() after processing each item
3. add all worker tasks to a list
4. join the queue
5. cancel all worker tasks.
6. wait until all worker tasks are cancelled

By adding asyncio.Queue.iter() and asyncio.Queue.iter_nowait(), this becomes a lot easier, you only need to call queue.shutdown(). The same applies to synchronous queues.

Has this already been discussed elsewhere?

No response given

Links to previous discussion of this feature:

• gh-119154: Simplify consumers by making queue.Queue an iterable #120503

Linked PRs

• gh-119154: Simplify consumers by adding *.Queue.iter() and *.Queue.iter_nowait() #120925
• gh-120924: Simplify consumers by adding asyncio.Queue.iter() and asyncio.Queue.iter_nowait() #120927