celery.concurrency.thread¶

Thread execution pool.

class celery.concurrency.thread.TaskPool(*args: Any, **kwargs: Any)[исходный код]¶

Thread Task Pool.

body_can_be_buffer = True¶

limit: int¶

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[исходный код]¶

on_stop() → None[исходный код]¶

signal_safe = False¶

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