Message90067
I have attached a patch. All I did was shift the one line from __init__
to _setup_queues.
That's it.
You could take advantage of the change in the following way:
class BlockingPool(pool.Pool):
def _setup_queues(self):
pool.Pool._setup_queues(self)
self._taskqueue = Queue(3)
self._inqueue = Queue(3)
self._quick_put = self._inqueue.put
Because of the design of _handle_tasks thread, you need to cap both
_taskqueue and _inqueue for blocking to work out.
I can't see any potential problems caused by this change, but I have
little experience working with this module so far. |
|
Date |
User |
Action |
Args |
2009-07-03 16:35:42 | masher | set | recipients:
+ masher, jnoller |
2009-07-03 16:35:41 | masher | set | messageid: <1246638941.62.0.598567477173.issue6407@psf.upfronthosting.co.za> |
2009-07-03 16:35:40 | masher | link | issue6407 messages |
2009-07-03 16:35:39 | masher | create | |
|