Events that can currently be listened to:
'ready': Emitted when the number of workers created in the pool has reached the minimum size expected and are ready.'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing at least one task.'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing concurrently their tasks quota.'full': Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected.destroy': Emitted when the pool is destroyed.'destroy': Emitted when the pool is destroyed.'error': Emitted when an uncaught error occurs.'taskError': Emitted when an error occurs while executing a task.'backPressure': Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size >= pool maximum size^2).'backPressure': Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size >= maximum queue size).Protected Readonly fileProtected Optional Readonly maxProtected Readonly numberProtected Readonly optsProtected promisePrivate startedWhether the pool is started or not.
+Private Readonly startingPrivate startingWhether the pool is starting or not.
Private Readonly taskThe task functions added at runtime map:
+key: The task function name.value: The task function itself.Protected workerReadonly Internal workerProtected fullProtected maxProtected minPrivate readyProtected Abstract typePrivate utilizationProtected Abstract workerAdds a task function to this pool. +If a task function with the same name already exists, it will be overwritten.
+The name of the task function.
+The task function.
+true if the task function was added, false otherwise.
https://nodejs.org/api/errors.html#class-typeerror If the name parameter is not a string or an empty string.
https://nodejs.org/api/errors.html#class-typeerror If the fn parameter is not a function.
Private addhttps://nodejs.org/api/errors.html#class-error If the added worker node is not found.
Protected afterProtected afterProtected beforePrivate buildPrivate checkPrivate checkPrivate checkProtected checkPrivate checkPrivate checkThe received message.
https://nodejs.org/api/errors.html#class-error If the worker id is invalid.
Private checkPrivate checkPrivate checkPrivate checkPrivate checkPrivate chooseProtected createProtected createProtected Abstract createPrivate deletePrivate dequeueProtected Abstract deregisterDeregisters a listener callback on the worker given its worker node key.
+The worker node key.
+The message listener callback.
+Protected Abstract destroyEnables/disables the worker tasks queue in this pool.
+Enables/disables the worker node tasks queue in this pool.
Whether to enable or disable the worker tasks queue.
+Whether to enable or disable the worker node tasks queue.
Optional tasksQueueOptions: TasksQueueOptionsThe worker tasks queue options.
+The worker node tasks queue options.
Private enqueuePrivate executeProtected flushPrivate flushProtected getPrivate getPrivate getThe worker id.
Private handlePrivate handlePrivate hasProtected internalProtected Abstract isPrivate redistributeProtected Abstract registerRegisters once a listener callback on the worker given its worker node key.
+The worker node key.
+The message listener callback.
+Protected Abstract registerPrivate removeProtected sendProtected Abstract sendPrivate sendPrivate sendPrivate sendProtected Abstract sendPrivate setSets the worker tasks queue options in this pool.
+Sets the worker node tasks queue options in this pool.
The worker tasks queue options.
+The worker node tasks queue options.
Private setPrivate setProtected setupPrivate shallPrivate shallPrivate shallPrivate startPrivate taskPrivate tasksPrivate tasksPrivate unsetPrivate unsetPrivate updatePrivate updatePrivate updatePrivate updatePrivate updateProtected workerGenerated using TypeDoc
Generated using TypeDoc
+ \ No newline at end of file
The task execution response promise map.
+The task execution response promise map:
key: The message id of each submitted task.value: An object that contains the worker, the execution response promise resolve and reject callbacks.PrivateReadonlystart