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, TerminateWorkers

Inherited from workerpool.WorkerPool (private): _AddTaskUnlocked, _HasRunningTasksUnlocked, _NewWorkerIdUnlocked, _ResizeUnlocked, _ShouldWorkerTerminateUnlocked, _WaitForTaskUnlocked, _WaitWhileQuiescingUnlocked

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)

Class _JobQueueWorkerPool

__init__(self, queue) (Constructor)

init(self, queue)
(Constructor)