Module workerpoolmanager :: Class WorkerPoolManager

[frames] | no frames]

Class WorkerPoolManager

source code

Instance Methods

[hide private]

__init__(self, appServer)
Creates the worker pool manager object.

source code

start(*args, **kwargs)
Starts the actual worker pool.

source code

run(*args, **kwargs)
Runs a job specified by arguments.

source code

integer

activeProcessCount(self)
Returns the number of active processes.

source code

integer

availableProcesses(self)
Returns the number of available idle processes.

source code

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, appServer)
(Constructor)

source code

Creates the worker pool manager object.

Parameters:

appServer - Owner Application Server of this worker pool.

Overrides: object.__init__

start(*args, **kwargs)

source code

Starts the actual worker pool.

Parameters:

numberOfWorkers (integer) - Indicates the default size of the worker pool.

Returns:

Deferred that will fire up when the pool is ready.

Decorators:

@defer.inlineCallbacks

run(*args, **kwargs)

source code

Runs a job specified by arguments.

Parameters:

callName (string) - Entry point (function name) of job (which is defined in jobtemplate.py)
args - Remote call parameters
kw - Remote call keyword parameters

Returns:

Job result.

Decorators:

@defer.inlineCallbacks

activeProcessCount(self)

source code

Returns the number of active processes.

Returns: integer: Number of active (busy) processes

availableProcesses(self)

source code

Returns the number of available idle processes.

Returns: integer: Number of available idle processes.

Class WorkerPoolManager

__init__(self, appServer) (Constructor)

start(*args, **kwargs)

run(*args, **kwargs)

activeProcessCount(self)

availableProcesses(self)

init(self, appServer)
(Constructor)