Message110193
This patch adds the `waitforslot` argument to apply_async. If set to `True`, apply_async will not return until there is a worker available to process the job.
This is implemented by a semaphore that is released by the result handler whenever a new result is ready. The semaphore is also released
when the supervisor (worker_handler) finds a worker process that has been
unexpectedly terminated.
This is already in use by Celery 2.0, which ships with its own modified version of multiprocessing.pool.
I'm not sure about the name ``waitforslot``, I think I may even hate it, but haven't been able to come up with a better name for it yet. |
|
Date |
User |
Action |
Args |
2010-07-13 13:47:04 | asksol | set | recipients:
+ asksol, jnoller |
2010-07-13 13:47:03 | asksol | set | messageid: <1279028823.93.0.963356654708.issue9248@psf.upfronthosting.co.za> |
2010-07-13 13:47:02 | asksol | link | issue9248 messages |
2010-07-13 13:47:01 | asksol | create | |
|