Package ganeti :: Module jqueue :: Class _JobQueueWorkerPool
[hide private]
[frames] | no frames]

Class _JobQueueWorkerPool

source code


Simple class implementing a job-processing workerpool.

Instance Methods [hide private]
 
__init__(self, queue)
Constructor for worker pool.
source code

Inherited from workerpool.WorkerPool: AddManyTasks, AddTask, ChangeTaskPriority, HasRunningTasks, Quiesce, Resize, SetActive, TerminateWorkers

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

Instance Variables [hide private]

Inherited from workerpool.WorkerPool (private): _taskdata, _tasks

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, queue)
(Constructor)

source code 

Constructor for worker pool.

Parameters:
  • num_workers - number of workers to be started (dynamic resizing is not yet implemented)
  • worker_class - the class to be instantiated for workers; should derive from BaseWorker
Overrides: object.__init__
(inherited documentation)