Feature or enhancement

Proposal:

Currently consuming items from a queue can be a bit more complex than necessary. You need to

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

By allowing iteration over *.Queue, this becomes a bit easier, you only need to call queue.shutdown().

Has this already been discussed elsewhere?

No response given

Links to previous discussion of this feature:

• Add asyncio.Queue.__aiter__ #119154
• Simplify consumers by making queue.Queue an iterable #120499
• Simplify consumers by adding *.Queue.iter() and *.Queue.iter_nowait() #120924

Linked PRs

• Implementation A: add asyncio.Queue.__aiter__() and queue.Queue.__iter__()
  • gh-119154: Simplify consumers by making asyncio.Queue an asynchronous iterable #120491
  • gh-119154: Simplify consumers by making queue.Queue an iterable #120503
• Implementation B: add *.Queue.iter() and *.Queue.iter_nowait()
  • gh-119154: Simplify consumers by adding *.Queue.iter() and *.Queue.iter_nowait() #120925