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

開始する前に、リンクされている pull requests と、以前の Queue の終了に関する議論を確認してください。この作業はすでに複数の場所で検討されています。要求されている動作は threading queue、multiprocessing queue、asyncio にまたがります。シャットダウンでは、今後の put を拒否し、待機中の処理をブロック解除し、draining 後に get が例外を発生させる必要があります。immediate=True の場合は draining を行いません。