Get multiprocessing.Queue to do priorities

uuid M8R-gqmgb4 at
Sun May 10 16:30:53 CEST 2009

Dear Jesse,
thanks for the hint.

I see you are already assigned to the FIFO bug 
(, so I won't burden you even more. 
Clearly, a reliable FIFO behavior of multiprocessing.Queue helps more 
than a priority queue, since it can be used to build one, so that 
should really be the first thing to fix.

In the meantime, I think I'll whip up a hack that uses sort of a 
bucket- strategy: fill up a prioritized heapq, and then, in regular 
intervals, unload its contents into a size-limited multiprocessing 

I'll post this as soon as it works.


On 2009-05-10 15:35:03 +0200, Jesse Noller <jnoller at> said:

> Using a manager, or submitting a patch which adds priority queue to
> the multiprocessing.queue module is the correct solution for this.
> You can file an enhancement in the tracker, and assign/add me to it,
> but without a patch it may take me a bit (wicked busy right now).
> jesse

More information about the Python-list mailing list