Get multiprocessing.Queue to do priorities
M8R-gqmgb4 at mailinator.com
Sun May 10 16:30:53 CEST 2009
thanks for the hint.
I see you are already assigned to the FIFO bug
(http://bugs.python.org/issue4999), 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 gmail.com> 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).
More information about the Python-list