I spawn one or more new Python interpreters that run a WireServer on the local machine.

Method	__init__	Undocumented
Method	shutdown	Undocumented
Method	spawn	Spawns a subordinate Python interpreter.
Method	newSocket	No summary
Method	done	Undocumented

def __init__(self, wwuFQN=None):

Undocumented

@defer.inlineCallbacks
def shutdown(self):

Undocumented

@defer.inlineCallbacks
def spawn(self, description, stdio=False, niceness=0):

Spawns a subordinate Python interpreter.

TODO: Implement (somehow) niceness keyword to accept an integer UNIX nice level for the new interpreter process.

Parameters	description	A server description string of the form used by Twisted's `endpoints.serverFromString`.
Returns	A `Deferred` that fires when the new process is running. If in stdio mode, it fires with a `util.ProcessProtocol` (which includes a pid attribute) for the new process. Otherwise, fires with the integer pid of the new process.

def newSocket(self):

Assigns a unique name to a socket file in a temporary directory common to all processes spawned by me, which will be removed with all socket files after reactor shutdown. Doesn't actually create the socket file; the server does that.

Returns An endpoint description using the new socket filename.

@defer.inlineCallbacks
def done(self, pid=None):

Undocumented

API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.

asynqueue.wire.ServerManager(object) class documentation

`asynqueue.wire.ServerManager(object)` class documentation