Class AsyncProcess
A coroutine-compatible multiprocessing.Process-alike. All normally blocking methods are wrapped in Tornado coroutines.
Declaration
class AsyncProcess
source linkDocumentation
Methods
▷ def __init__(self, loop=None, target=None, name=None, args=(), kwargs={}) ▷ def close(self) Stop helper thread and release resources. This method returns immediately and does not ensure the child process has exited.
@property
def daemon(self)
▷ def daemon(self, value) @daemon.setter @daemon.setter
def daemon(
self,
value,
)
@property
def exitcode(self)
▶ def join(self, timeout=None) @gen.coroutine Wait for the child process to exit.
@gen.coroutine
def join(
self,
timeout=None,
)
This method is a coroutine.
▷ def name(self) @property ▷ def pid(self) @property ▶ def set_exit_callback(self, func) Set a function to be called by the event loop when the process exits. The function is called with the AsyncProcess as sole argument.
The function may be a coroutine function.
▶ def start(self) Start the child process.
This method is a coroutine.
▶ def terminate(self) Terminate the child process.
This method is a coroutine.
Class methods
▶ def reset_logger_locks() @staticmethod Python 2's logger's locks don't survive a fork event
@staticmethod
def reset_logger_locks()
https://github.com/dask/distributed/issues/1491
Reexports