Package papyros :: Module singlethreaded :: Class SingleThreadedMaster
[hide private]
[frames] | no frames]

Class SingleThreadedMaster

source code

object --+    
         |    
    Master --+
             |
object --+   |
         |   |
     Slave --+
             |
            SingleThreadedMaster

Instance Methods [hide private]
 
__init__(self, poll_time=1, request_qsize=0, response_qsize=0)
Initialize this master.
source code
 
popProcessedJob(self, timeout=None)
Pop the next processed Job from the output queue.
source code

Inherited from Master: addJob, cancelAllJobs, numPendingJobs, processedJobs

Inherited from Master (private): _assignJob, _getProcessedJob

Inherited from Slave: process, run

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, poll_time=1, request_qsize=0, response_qsize=0)
(Constructor)

source code 
Initialize this master.
Overrides: Master.__init__
(inherited documentation)

popProcessedJob(self, timeout=None)

source code 

Pop the next processed Job from the output queue.

If there are no pending jobs, it returns None. Otherwise:
  • If timeout is None, block until a job has finished and return it.
  • If timeout <= 0, return the first finished job that is immediately available without blocking, or None otherwise.
  • If timeout > 0, wait up to timeout seconds for a job to finish and return it; return None if no job has finished by the deadline.
Returns:
The next processed Job or None if there is no available for the given timeout.
Overrides: Master.popProcessedJob
(inherited documentation)