This document describes the current stable version of Celery (5.5). For development docs, go here.
celery.concurrency.thread
¶
Thread execution pool.
- class celery.concurrency.thread.TaskPool(*args: Any, **kwargs: Any)[source]¶
Thread Task Pool.
- body_can_be_buffer = True¶
- on_apply(target: TargetFunction, args: tuple[Any, ...] | None = None, kwargs: dict[str, Any] | None = None, callback: Callable[..., Any] | None = None, accept_callback: Callable[..., Any] | None = None, **_: Any) ApplyResult [source]¶
- signal_safe = False¶
set to true if the pool can be shutdown from within a signal handler.