a.p.ProcessUniverse(object) : class documentation

Part of asynqueue.process View In Hierarchy Source for process.py Main doc for AsynQueue

Each process for a ProcessWorker lives in one of these.

Method __init__ Undocumented
Method loop Runs a loop in a dedicated process that waits for new tasks. The loop exits when a None object is supplied as a task.
Method next My loop calls this when the interprocess pipe sends it a string identifier for one of the iterators I have pending.
def __init__(self, raw=False, callStats=False):
Undocumented
def loop(self, connection):

Runs a loop in a dedicated process that waits for new tasks. The loop exits when a None object is supplied as a task.

Parameters connection The sub-process end of an interprocess connection.
def next(self, ID):

My loop calls this when the interprocess pipe sends it a string identifier for one of the iterators I have pending.

Returns A 2-tuple with the specified iterator's next value, and a bool indicating if the value was valid or a bogus None resulting from a StopIteration error or a non-existent iterator. (type: tuple)
API Documentation for AsynQueue, generated by pydoctor at 2016-11-16 14:52:11.