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

Überprüfe die verknüpften pull requests und die vorherige Diskussion zur Queue-Terminierung, bevor du beginnst, da die Arbeit bereits an mehreren Stellen untersucht wurde. Das angeforderte Verhalten betrifft threading queue, multiprocessing queue und asyncio: Das Herunterfahren sollte zukünftige put-Aufrufe ablehnen, wartende Aufrufer entsperren und get-Aufrufe nach dem Leeren eine Ausnahme auslösen lassen, wobei immediate=True das Leeren umgeht.