Queue shutdown

Add a shutdown method to queue class (threading queue, multiprocessing, asyncio) which causes all future puts to raise (a queue.QueueShutdown) and all future gets once the queue is empty to also raise, unblocking all waiters. An optional argument immediate=True will skip the requirement for the queue to be empty.

This will enable producers and consumers to use the queue to know when to stop. This is important because both producers and consumers can be blocked waiting on the queue.

Previous discussion:

• queue termination on Discourse
• #81515

Linked PRs

• gh-96474
• gh-102499
• gh-104225
• gh-104228
• gh-104230
• gh-104750
• gh-115265
• gh-115838
• gh-116699
• gh-117621
• gh-138828

Hãy xem xét các pull requests được liên kết và cuộc thảo luận trước đây về việc kết thúc Queue trước khi bắt đầu, vì công việc này đã được khám phá ở một số nơi. Hành vi được yêu cầu bao phủ threading queue, multiprocessing queue và asyncio: việc shutdown phải từ chối các put trong tương lai, bỏ chặn các waiter và khiến các get raise một exception sau khi drain, với immediate=True bỏ qua việc drain.