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

Examinez les pull requests liés et la discussion précédente sur l’arrêt de Queue avant de commencer, car le travail a déjà été exploré à plusieurs endroits. Le comportement demandé concerne threading queue, multiprocessing queue et asyncio : l’arrêt doit refuser les futurs put, débloquer les appelants en attente et faire lever une exception aux get après la vidange, avec immediate=True qui contourne la vidange.