Repository navigation
Simplify consumers with iteration over *.Queue #120947
Description
Feature or enhancement
Proposal:
Currently consuming items from a queue can be a bit more complex than necessary. You need to
- use an infinite while loop
- check for a sentinel or add all worker tasks to a list
- call q.task_done() after processing each item
- join the queue
- cancel all worker tasks
- 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__()
- Implementation B: add *.Queue.iter() and *.Queue.iter_nowait()
Activity
vstinner commented on Jun 24, 2024
Please keep discussions about alternatives in an unique issue, rather than opening one issue per alternative. I suggest to close this issue.
nineteendo commented on Jun 24, 2024
Huh? That's what this is, it's a single issue to discuss the alternative solutions.
vstinner commented on Jun 24, 2024
I'm asking the opposite: discuss your alternative in the existing issue, don't create a new issue just for an alternative.
nineteendo commented on Jun 24, 2024
OK, then I misunderstood this comment: