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.
Protected
nextId of the next message.
Readonly
numberNumber of workers that this pool should manage.
Readonly
optsOptions for this fixed cluster pool.
Protected
promiseThe promise map.
key
: This is the message Id of each submitted task.value
: An object that contains the worker, the resolve function and the reject function.When we receive a message from the worker we get a map entry and resolve/reject the promise based on the message.
Protected
workerWorker choice strategy instance implementing the worker choice algorithm.
Default to a strategy implementing a round robin algorithm.
Readonly
workers{@inheritDoc}
Readonly
workers{@inheritDoc}
{@inheritDoc}
{@inheritDoc}
{@inheritDoc}
Protected
afterHook executed after the worker task promise resolution. Can be overridden.
The received message.
The Promise response.
Protected
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