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

  Multiprocessing Pool implementation.

  BlockingPool

    alias of `Pool`

  Pool

    alias of `AsynPool`

  did_start_ok()
  property num_processes
  on_close()
  on_start()
  on_stop()

    Gracefully stop the pool.

  on_terminate()

    Force terminate the pool.

  register_with_event_loop(loop)
  restart()
  uses_semaphore = True

    only used by multiprocessing pool

  write_stats = None

celery.concurrency.prefork.process_destructor(pid, exitcode)

  Pool child process destructor.

  Dispatch the `worker_process_shutdown` signal.

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

  Pool child process initializer.

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