This issue tracker has been migrated to GitHub, and is currently read-only.
For more information, see the GitHub FAQs in the Python's Developer Guide.

Author asksol
Recipients asksol, jnoller
Date 2010-07-13.13:47:01
SpamBayes Score 0.053663466
Marked as misclassified No
Message-id <1279028823.93.0.963356654708.issue9248@psf.upfronthosting.co.za>
In-reply-to
Content
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.
History
Date User Action Args
2010-07-13 13:47:04asksolsetrecipients: + asksol, jnoller
2010-07-13 13:47:03asksolsetmessageid: <1279028823.93.0.963356654708.issue9248@psf.upfronthosting.co.za>
2010-07-13 13:47:02asksollinkissue9248 messages
2010-07-13 13:47:01asksolcreate