concurrency.prefork

Prefork execution pool.

Pool implementation using multiprocessing.

Module Contents

Classes

TaskPool() Multiprocessing Pool implementation.

Functions

process_initializer(app,hostname) Pool child process initializer.
process_destructor(pid,exitcode) Pool child process destructor.
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.

process_destructor(pid, exitcode)

Pool child process destructor.

Dispatch the :signal:`worker_process_shutdown` signal.

class TaskPool

Multiprocessing Pool implementation.

on_start()
restart()
did_start_ok()
register_with_event_loop(loop)
on_stop()

Gracefully stop the pool.

on_terminate()

Force terminate the pool.

on_close()
_get_info()
num_processes()