This document describes the current stable version of Celery (3.1). For development docs, go here.
celery.concurrency.prefork¶
celery.concurrency.prefork¶
Pool implementation using multiprocessing
.
-
class
celery.concurrency.prefork.
TaskPool
(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=(), **options)[source]¶ Multiprocessing Pool implementation.
-
Pool
¶ alias of
AsynPool
-
num_processes
¶
-
uses_semaphore
= True¶
-
write_stats
= None¶
-
-
celery.concurrency.prefork.
process_initializer
(app, hostname)[source]¶ Pool child process initializer.
This will initialize a child pool process to ensure the correct app instance is used and things like logging works.
-
celery.concurrency.prefork.
process_destructor
(pid, exitcode)[source]¶ Pool child process destructor
Dispatch the
worker_process_shutdown
signal.