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

celery.concurrency.thread

Thread execution pool.

class celery.concurrency.thread.TaskPool(*args, **kwargs)[source]

Thread Task Pool.

body_can_be_buffer = True
on_apply(target, args=None, kwargs=None, callback=None, accept_callback=None, **_)[source]
on_stop()[source]
signal_safe = False

set to true if the pool can be shutdown from within a signal handler.