This document describes an older version of Celery (2.1).
For the latest stable version please
go here.
Thread Pool Support EXPERIMENTAL - celery.concurrency.threads
-
class celery.concurrency.threads.TaskPool(limit, logger=None, **kwargs)
-
apply_async(target, args=None, kwargs=None, callbacks=None, errbacks=None, accept_callback=None, **compat)
-
on_ready(callbacks, errbacks, ret_value)
What to do when a worker task is ready and its return value has
been collected.
-
start()
-
stop()
-
celery.concurrency.threads.do_work(target, args=(), kwargs={}, callback=None, accept_callback=None)