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)