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)

Multiprocessing Pool implementation.

BlockingPool

alias of Pool

Pool

alias of AsynPool

did_start_ok()

num_processes

on_close()

on_start()

Run the task pool.

Will pre-fork all workers so they’re ready to accept tasks.

on_stop()

Gracefully stop the pool.

on_terminate()

Force terminate the pool.

register_with_event_loop(loop)

restart()

uses_semaphore = True

write_stats = None

celery.concurrency.prefork.process_initializer(app, hostname)

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)

Pool child process destructor

Dispatch the worker_process_shutdown signal.