| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Sorry, something went wrong.
|
Thank you! Unfortunately I don't know the multiprocessing code at all and I can't offer to review this. Maybe you can ask for help in the core development category on discuss.python.org. |
Sorry, something went wrong.
+ add ``Queue.shutdown` method, + update ``Queue.get``and ``Queue.put`` methods + add versionadded to ``get``and ``put``
Documentation build overview162 files changed · + 3 added · ± 158 modified · - 1 deleted + Added ± Modified
- Deleted |
Sorry, something went wrong.
| Back | FazBrowse Home | New Git URL |
Add multiprocessing queue shutdown
This feature is already implemented in asyncio(#104228) and threading (#104750) modules.
Reminders of new behaviors
When queue shuts down:
Updates to the main code.
There are 2 constraints here:
The additional private variables are as follows:
It would also have been possible to use an array of integers from mulitprocessing.heap.BufferWrapper but I find simpler and more explicit to use Semaphore.
The main additional codes are as follows: