Package papyros :: Module multithreaded :: Class MultiThreadedMaster
[hide private]
[frames] | no frames]

Class MultiThreadedMaster

source code

object --+    
         |    
    Master --+
             |
            MultiThreadedMaster

Instance Methods [hide private]
 
__init__(self, num_slaves, poll_time=1, request_qsize=0, response_qsize=0)
Initialize this master and start num_slaves slaves.
source code

Inherited from Master: addJob, cancelAllJobs, numPendingJobs, popProcessedJob, processedJobs

Inherited from Master (private): _assignJob, _getProcessedJob

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, num_slaves, poll_time=1, request_qsize=0, response_qsize=0)
(Constructor)

source code 
Initialize this master and start num_slaves slaves.
Parameters:
  • num_slaves - The number of slaves to start initially.
  • request_qsize - If a positive integer, it's the maximum number of unassigned jobs. Trying to add a new Job when the queue is full blocks or raises Queue.Full exception.
  • response_qsize - If a positive integer, it's the maximum number of completed jobs waiting to be fetched. No more jobs are assigned to the slaves when this number is reached.
Overrides: Master.__init__