draugr.multiprocessing_utilities.pooled_queue_processor¶
Classes
Uses cloudpickle to serialize contents (otherwise multiprocessing tries to use pickle) :param x: (Any) the variable you wish to wrap for pickling with cloudpickle |
|
Pooled queue task interface |
|
|
This is a workaround of Pythons extremely slow interprocess communication pipes. |