AbstractPool | poolifier

@@ -49,19 +49,19 @@

IPool<Worker, Data, Response>

Defined in src/pools/abstract-pool.ts:60

Index

busy full info maxSize @@ -87,7 +88,8 @@

Methods

addWorkerNode +

addTaskFunction +addWorkerNode afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook @@ -107,6 +109,7 @@ createAndSetupDynamicWorkerNode createAndSetupWorkerNode createWorker +deleteTaskFunctionWorkerUsages dequeueTask destroy destroyWorkerNode @@ -122,38 +125,49 @@ handleTaskExecutionResponse handleWorkerReadyResponse hasBackPressure +hasTaskFunction hasWorkerNodeBackPressure internalBusy isMain -listTaskFunctions +listTaskFunctionNames redistributeQueuedTasks registerWorkerMessageListener +removeTaskFunction removeWorkerNode sendKillMessageToWorker sendStartupMessageToWorker sendStatisticsMessageToWorker +sendTaskFunctionOperationToWorker +sendTaskFunctionOperationToWorkers sendToWorker -setTasksQueueMaxSize +setDefaultTaskFunction +setTaskStealing setTasksQueueOptions +setTasksQueueSize +setTasksStealingOnBackPressure setWorkerChoiceStrategy setWorkerChoiceStrategyOptions setupHook shallCreateDynamicWorker +shallExecuteTask shallUpdateTaskFunctionWorkerUsage -startPool +start taskStealingOnEmptyQueue tasksQueueSize tasksStealingOnBackPressure +unsetTaskStealing +unsetTasksStealingOnBackPressure updateEluWorkerUsage updateRunTimeWorkerUsage updateTaskStatisticsWorkerUsage +updateTaskStolenStatisticsWorkerUsage updateWaitTimeWorkerUsage workerListener

Constructors

constructor

new AbstractPool<Worker, Data, Response>(numberOfWorkers, filePath, opts): AbstractPool<Worker, Data, Response>
@@ -189,7 +203,7 @@
Returns AbstractPool<Worker, Data, Response>
- Defined in src/pools/abstract-pool.ts:113

Defined in src/pools/abstract-pool.ts:122

Properties

@@ -199,9 +213,9 @@

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 >= maximum queue size).

Defined in src/pools/abstract-pool.ts:69

`Protected` `Readonly` filePath

filePath: string

@@ -218,7 +232,7 @@

Defined in src/pools/abstract-pool.ts:124

`Protected` `Optional` `Readonly` max

max?: number

@@ -226,7 +240,7 @@

Methods

addTaskFunction

addTaskFunction(name, fn): Promise<boolean>
+
Adds a task function to this pool. +If a task function with the same name already exists, it will be overwritten.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
- +
  fn: TaskFunction<Data, Response>
  +
  The task function.
  +
  +
+
Returns Promise<boolean>
true if the task function was added, false otherwise.
+ +
+
Throws
https://nodejs.org/api/errors.html#class-typeerror If the name parameter is not a string or an empty string.
+ +
Throws
https://nodejs.org/api/errors.html#class-typeerror If the fn parameter is not a function.
+
+
Implementation of IPool.addTaskFunction
+
- Defined in src/pools/abstract-pool.ts:856

Index

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

constructor

Returns AbstractPool<Worker, Data, Response>

Properties

Protected Readonly filePath

Protected Optional Readonly max

Protected Readonly numberOfWorkers

Protected Readonly opts

Protected promiseResponseMap

Private Readonly startTimestamp

Private started

Private Readonly starting

Private starting

Private Readonly taskFunctions

Protected workerChoiceStrategyContext

Readonly Internal workerNodes

Accessors

Returns boolean

Protected full

Returns boolean

info

Protected maxSize

Returns number

Protected minSize

Returns number

Private ready

Returns boolean

Protected Abstract type

Returns "fixed" | "dynamic"

Private utilization

Protected Abstract worker

Returns "thread" | "cluster"

Methods

addTaskFunction

Parameters

name: string

fn: TaskFunction<Data, Response>

Returns Promise<boolean>

Throws

Throws

Private addWorkerNode

Throws

Protected afterTaskExecutionHook

Returns void

Protected afterWorkerNodeSetup

Returns void

Protected beforeTaskExecutionHook

Returns void

Private buildTasksQueueOptions

tasksQueueOptions: TasksQueueOptions

Returns TasksQueueOptions

Private checkAndEmitDynamicWorkerCreationEvents

Returns void

Private checkAndEmitTaskExecutionEvents

Returns void

Private checkAndEmitTaskQueuingEvents

Returns void

Protected checkDynamicPoolSize

max: number

Returns void

Private checkFilePath

filePath: string

Returns void

Private checkMessageWorkerId

Throws

Private checkNumberOfWorkers

numberOfWorkers: number

Returns void

Private checkPoolOptions

opts: PoolOptions<Worker>

Returns void

Private checkValidTasksQueueOptions

Parameters

`Protected` `Readonly` filePath

`Protected` `Optional` `Readonly` max

`Protected` `Readonly` numberOfWorkers

`Protected` `Readonly` opts

`Protected` promiseResponseMap

`Private` `Readonly` startTimestamp

`Private` started

`Private` `Readonly` starting

`Private` starting

`Private` `Readonly` taskFunctions

`Protected` workerChoiceStrategyContext

`Readonly` `Internal` workerNodes

`Protected` full

`Protected` maxSize

`Protected` minSize

`Private` ready

`Protected` `Abstract` type

`Private` utilization

`Protected` `Abstract` worker

`Private` addWorkerNode

`Protected` afterTaskExecutionHook

`Protected` afterWorkerNodeSetup

`Protected` beforeTaskExecutionHook

`Private` buildTasksQueueOptions

`Private` checkAndEmitDynamicWorkerCreationEvents

`Private` checkAndEmitTaskExecutionEvents

`Private` checkAndEmitTaskQueuingEvents

`Protected` checkDynamicPoolSize

`Private` checkFilePath

`Private` checkMessageWorkerId

`Private` checkNumberOfWorkers

`Private` checkPoolOptions

`Private` checkValidTasksQueueOptions

`Private` checkValidWorkerChoiceStrategy

`Private` checkValidWorkerChoiceStrategyOptions

`Private` chooseWorkerNode

`Protected` createAndSetupDynamicWorkerNode

`Protected` createAndSetupWorkerNode

`Protected` `Abstract` createWorker

`Private` deleteTaskFunctionWorkerUsages

`Private` dequeueTask

`Protected` `Abstract` destroyWorkerNode

`Private` enqueueTask

`Private` executeTask

`Protected` flushTasksQueue

`Private` flushTasksQueues

`Protected` getWorkerInfo

`Private` getWorkerNodeKeyByWorker

`Private` getWorkerNodeKeyByWorkerId

`Private` handleTaskExecutionResponse

`Private` handleWorkerReadyResponse

`Private` hasBackPressure

`Protected` internalBusy

`Protected` `Abstract` isMain

`Private` redistributeQueuedTasks

`Protected` `Abstract` registerWorkerMessageListener