DynamicClusterPool | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicClusterPool.html;h=5b2e41c469fad567ee589be0967741fee5ef8c44;hb=4608939f425568da5553db1f5bf883d4cca18e02;hp=bd7ff22c30c91322460aab11bb2d90569bc0bc8d;hpb=adab53c70d781f8c26e35b7359efa3d05c278fa8;p=poolifier.git diff --git a/docs/classes/DynamicClusterPool.html b/docs/classes/DynamicClusterPool.html index bd7ff22c..5b2e41c4 100644 --- a/docs/classes/DynamicClusterPool.html +++ b/docs/classes/DynamicClusterPool.html @@ -1,13 +1,13 @@ -DynamicClusterPool | poolifier - v2.6.39

@@ -45,19 +45,19 @@ When the maximum number of workers is reached and workers are busy, an event is

DynamicClusterPool

Defined in src/pools/cluster/dynamic.ts:15

Index

Constructors

constructor +

constructor

Properties

emitter? +

emitter? filePath max numberOfWorkers @@ -68,7 +68,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Accessors

busy +

busy full info maxSize @@ -80,7 +80,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Methods

afterTaskExecutionHook +

afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook checkDynamicPoolSize @@ -105,12 +105,13 @@ When the maximum number of workers is reached and workers are busy, an event is setWorkerChoiceStrategy setWorkerChoiceStrategyOptions setupHook +start workerListener

Constructors

constructor

new DynamicClusterPool<Data, Response>(min, max, filePath, opts?): DynamicClusterPool<Data, Response>
@@ -129,24 +130,28 @@ When the maximum number of workers is reached and workers are busy, an event is
min: number

Minimum number of workers which are always active.
-

max: number

Maximum number of workers that can be created by this pool.

filePath: string

Path to an implementation of a ClusterWorker file, which can be relative or absolute.

opts: ClusterPoolOptions = {}

Options for this dynamic cluster pool.

+ +

Returns DynamicClusterPool<Data, Response>

Defined in src/pools/cluster/dynamic.ts:27

Properties

@@ -167,7 +172,7 @@ When the maximum number of workers is reached and workers are busy, an event is

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

`Protected` `Readonly` filePath

filePath: string

@@ -176,7 +181,7 @@ When the maximum number of workers is reached and workers are busy, an event is

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

`Protected` `Readonly` max

max: number

@@ -185,7 +190,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/dynamic.ts:29

`Protected` `Readonly` numberOfWorkers

numberOfWorkers: number

@@ -194,7 +199,7 @@ When the maximum number of workers is reached and workers are busy, an event is

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

`Protected` `Readonly` opts

opts: ClusterPoolOptions = {}

@@ -203,11 +208,11 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/fixed.ts:47

`Protected` promiseResponseMap

promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...

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.

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

`Protected` workerChoiceStrategyContext

workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>

@@ -226,7 +231,7 @@ When the maximum number of workers is reached and workers are busy, an event is

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

`Readonly` `Internal` workerNodes

workerNodes: IWorkerNode<Worker, Data>[] = []

@@ -235,7 +240,7 @@ When the maximum number of workers is reached and workers are busy, an event is

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

Accessors

@@ -250,7 +255,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/dynamic.ts:43

Methods

@@ -366,16 +371,18 @@ Can be overridden.

workerNodeKey: number

The worker node key.

+ +

message: MessageValue<Response, unknown>

The received message.

+ +

Returns void

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

`Protected` afterWorkerNodeSetup

workerNodeKey: number

The newly created worker node key.
-

+ +

Returns void

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

`Protected` beforeTaskExecutionHook

workerNodeKey: number

The worker node key.
-

task: Task<Data>

The task to execute.
-

+ +

Returns void

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

`Protected` checkDynamicPoolSize

Returns void

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

`Protected` createAndSetupDynamicWorkerNode

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

`Protected` createAndSetupWorkerNode

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

`Protected` createWorker

Defined in src/pools/cluster/fixed.ts:109

destroy

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

`Protected` destroyWorkerNode

workerNodeKey: number

The worker node key.
-

+ +

Returns Promise<void>

Defined in src/pools/cluster/fixed.ts:63

enableTasksQueue

enable: boolean

Whether to enable or disable the worker node tasks queue.
-

Optional tasksQueueOptions: TasksQueueOptions

The worker node tasks queue options.
-
Optional

+ +

Returns void

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

execute

Optional data: Data

The optional task input data for the specified task function. This can only be structured-cloneable data.
-
Optional

Optional name: string

The optional name of the task function to execute. If not specified, the default task function will be executed.
-
Optional

Optional transferList: TransferListItem[]

An optional array of transferable objects to transfer ownership of. Ownership of the transferred objects is given to the pool's worker_threads worker and they should not be used in the main thread afterwards.
-
Optional

+ +

Returns Promise<Response>

Promise that will be fulfilled when the task is completed.

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

`Protected` flushTasksQueue

Returns void

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

`Protected` getWorkerInfo

getWorkerInfo(workerNodeKey): undefined | WorkerInfo
getWorkerInfo(workerNodeKey): WorkerInfo
Gets the worker information given its worker node key.

@@ -584,13 +600,14 @@ Can be overridden.
workerNodeKey: number

The worker node key.
-

Returns undefined | WorkerInfo

The worker information.

+ +

Returns WorkerInfo

The worker information.

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

hasWorkerNodeBackPressure

workerNodeKey: number

The worker node key.
-

+ +

Returns boolean

true if the worker node has back pressure, false otherwise.

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

`Protected` internalBusy

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

`Protected` isMain

Defined in src/pools/cluster/fixed.ts:58

listTaskFunctions

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

`Protected` registerWorkerMessageListener

workerNodeKey: number

The worker node key.
-

listener: ((message) => void)

The message listener callback.

+

Defined in src/pools/cluster/fixed.ts:101

`Protected` sendKillMessageToWorker

Returns Promise<void>

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

`Protected` sendStartupMessageToWorker

workerNodeKey: number

The worker node key.
-

+ +

Returns void

Defined in src/pools/cluster/fixed.ts:93

`Protected` sendToWorker

workerNodeKey: number

The worker node key.
-

message: MessageValue<Data, unknown>

The message.
-

+ +

Returns void

Defined in src/pools/cluster/fixed.ts:85

setTasksQueueOptions

tasksQueueOptions: TasksQueueOptions

The worker node tasks queue options.
-

+ +

Returns void

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

setWorkerChoiceStrategy

workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN"

The worker choice strategy.
-

Optional workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

The worker choice strategy options.
-
Optional

+ +

Returns void

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

setWorkerChoiceStrategyOptions

workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

The worker choice strategy options.
-

+ +

Returns void

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

`Protected` setupHook

Defined in src/pools/cluster/fixed.ts:53

start

start(): void
+
Starts the minimum number of workers in this pool.
+
+
Returns void
+
+
Inherited from FixedClusterPool.start
+
- Defined in src/pools/abstract-pool.ts:788

`Protected` workerListener

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

Generated using TypeDoc

\ No newline at end of file +

\ No newline at end of file

Index

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

constructor

min: number

max: number

filePath: string

opts: ClusterPoolOptions = {}

Returns DynamicClusterPool<Data, Response>

Properties

Protected Readonly filePath

Protected Readonly max

Protected Readonly numberOfWorkers

Protected Readonly opts

Protected promiseResponseMap

Protected workerChoiceStrategyContext

Readonly Internal workerNodes

Accessors

Protected full

info

Protected maxSize

Protected minSize

Private ready

Protected type

Private utilization

Protected worker

Methods

workerNodeKey: number

message: MessageValue<Response, unknown>

Returns void

Protected afterWorkerNodeSetup

workerNodeKey: number

Returns void

Protected beforeTaskExecutionHook

workerNodeKey: number

task: Task<Data>

Returns void

Protected checkDynamicPoolSize

Returns void

Protected createAndSetupDynamicWorkerNode

Protected createAndSetupWorkerNode

Protected createWorker

destroy

Protected destroyWorkerNode

workerNodeKey: number

Returns Promise<void>

enableTasksQueue

enable: boolean

Optional tasksQueueOptions: TasksQueueOptions

Returns void

execute

Optional data: Data

Optional name: string

Optional transferList: TransferListItem[]

Returns Promise<Response>

Protected flushTasksQueue

Returns void

Protected getWorkerInfo

workerNodeKey: number

Returns undefined | WorkerInfo

Returns WorkerInfo

hasWorkerNodeBackPressure

workerNodeKey: number

Returns boolean

Protected internalBusy

Protected isMain

listTaskFunctions

Protected registerWorkerMessageListener

workerNodeKey: number

listener: ((message) => void)

Protected sendKillMessageToWorker

Returns Promise<void>

Protected sendStartupMessageToWorker

workerNodeKey: number

Returns void

`Protected` `Readonly` filePath

`Protected` `Readonly` max

`Protected` `Readonly` numberOfWorkers

`Protected` `Readonly` opts

`Protected` promiseResponseMap

`Protected` workerChoiceStrategyContext

`Readonly` `Internal` workerNodes

`Protected` full

`Protected` maxSize

`Protected` minSize

`Private` ready

`Protected` type

`Private` utilization

`Protected` worker

`Protected` afterWorkerNodeSetup

`Protected` beforeTaskExecutionHook

`Protected` checkDynamicPoolSize

`Protected` createAndSetupDynamicWorkerNode

`Protected` createAndSetupWorkerNode

`Protected` createWorker

`Protected` destroyWorkerNode

`Optional` tasksQueueOptions: TasksQueueOptions

`Optional` data: Data

`Optional` name: string

`Optional` transferList: TransferListItem[]

`Protected` flushTasksQueue

`Protected` getWorkerInfo

`Protected` internalBusy

`Protected` isMain

`Protected` registerWorkerMessageListener

`Protected` sendKillMessageToWorker

`Protected` sendStartupMessageToWorker

`Protected` sendToWorker

`Optional` workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

`Protected` setupHook

`Protected` workerListener