This document describes the current stable version of Celery (3.1). For development docs,
go here.
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.
-
BlockingPool
alias of Pool
-
Pool
alias of AsynPool
-
did_start_ok()[source]
-
num_processes[source]
-
on_close()[source]
-
on_start()[source]
Run the task pool.
Will pre-fork all workers so they’re ready to accept tasks.
-
on_stop()[source]
Gracefully stop the pool.
-
on_terminate()[source]
Force terminate the pool.
-
register_with_event_loop(loop)[source]
-
restart()[source]
-
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.