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, HasRunningTasks, Quiesce, Resize, SetActive, TerminateWorkers

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

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, queue)

source code 

Constructor for worker pool.

  • 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)