This document describes the current stable version of Celery (5.5). For development docs, go here.
celery.concurrency.prefork
¶
Prefork execution pool.
Pool implementation using multiprocessing
.
- class celery.concurrency.prefork.TaskPool(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=(), app=None, **options)[source]¶
Multiprocessing Pool implementation.
- BlockingPool¶
alias of
Pool
- Pool¶
alias of
AsynPool
- property num_processes¶
- uses_semaphore = True¶
only used by multiprocessing pool
- write_stats = None¶
- celery.concurrency.prefork.process_destructor(pid, exitcode)[source]¶
Pool child process destructor.
Dispatch the
worker_process_shutdown
signal.