This document describes the current stable version of Celery (3.1). For development docs, go here.

celery.concurrency.threads‡ (minefield)

celery.concurrency.threads

Pool implementation using threads.

class celery.concurrency.threads.TaskPool(*args, **kwargs)[source]
on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, **_)[source]
on_start()[source]
on_stop()[source]