celery.concurrency.prefork

• 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

  Pool 的别名

• Pool

  AsynPool 的别名

• did_start_ok()[源代码]

• num_processes None[源代码]

• 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.