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)

Previous topic

extended multiprocessing.pool - celery.concurrency.processes.pool

Next topic

Clock Service - celery.beat

This Page