Type of data sent to the worker. This can only be serializable data.
Type of response of execution. This can only be serializable data.
Constructs a new poolifier fixed cluster pool.
Number of workers for this pool.
Path to an implementation of a ClusterWorker
file, which can be relative or absolute.
Options for this fixed cluster pool.
Optional
Readonly
emitter{@inheritDoc}
Readonly
filePath to the worker-file.
Readonly
numberNumber of workers that this pool should manage.
Readonly
optsOptions for this fixed cluster pool.
Protected
promiseThe promise response map.
key
: The message id of each submitted task.value
: An object that contains the worker, the promise resolve and reject callbacks.When we receive a message from the worker we get a map entry with the promise resolve/reject bound to the message.
Protected
workerWorker choice strategy instance implementing the worker choice algorithm.
Default to a strategy implementing a round robin algorithm.
Readonly
workers{@inheritDoc}
{@inheritDoc}
{@inheritDoc}
Private
numberNumber of tasks concurrently running.
{@inheritDoc}
Protected
afterProtected
afterProtected
beforeProtected
chooseProtected
createProtected
createProtected
internalProtected
is{@inheritDoc}
Protected
removeProtected
sendProtected
setupProtected
workerThis function is the listener registered for each worker.
The listener function to execute when a message is received from a worker.
This function is the listener registered for each worker.
The listener function to execute when a message is received from a worker.
Generated using TypeDoc
A cluster pool with a fixed number of workers.
It is possible to perform tasks in sync or asynchronous mode as you prefer.
This pool selects the workers in a round robin fashion.
Author
Christopher Quadflieg
Since
2.0.0