This document describes the current stable version of Celery (5.0). 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 billiard.pool.Pool

Pool

alias of celery.concurrency.asynpool.AsynPool

did_start_ok()[source]
property num_processes
on_close()[source]
on_start()[source]
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_destructor(pid, exitcode)[source]

Pool child process destructor.

Dispatch the worker_process_shutdown signal.

celery.concurrency.prefork.process_initializer(app, hostname)[source]

Pool child process initializer.

Initialize the child pool process to ensure the correct app instance is used and things like logging works.