eta.core.eta.ProcessManager
- class ProcessManager(address=None, authkey=None, serializer='pickle', ctx=None)[source]
Bases:
BaseManager
Manager to handle multiprocessing.
Methods
Connect manager object to the server process
Return server object with serve_forever() method and address attribute
Join the manager process (if it has been spawned)
Register a typeid with the manager type
Spawn a server process for this manager object
Attributes
address
- connect()
Connect manager object to the server process
- get_server()
Return server object with serve_forever() method and address attribute
- join(timeout=None)
Join the manager process (if it has been spawned)
- classmethod register(typeid, callable=None, proxytype=None, exposed=None, method_to_typeid=None, create_method=True)
Register a typeid with the manager type
- start(initializer=None, initargs=())
Spawn a server process for this manager object