你正在阅读 Celery 3.1 的文档。开发版本文档见： 此处.

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.