AbstractPool | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=8fe5465a5779a9b05f3f4b5f14d45f5c6722595d;hb=a6b5c73ccccb3ef0ccc24ad462182e3cacee77b4;hp=51fda18c1a4652e54b40f9dfbc94118aebd80073;hpb=71056a0ac555e096c1428d6341ef45c7980a6332;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 51fda18c..8fe5465a 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier

+AbstractPool | poolifier - v2.6.9

@@ -29,12 +29,12 @@

Data = unknown

Type of data sent to the worker. This can only be serializable data.

Type of data sent to the worker. This can only be structured-cloneable data.

Response = unknown

Type of execution response. This can only be serializable data.

Type of execution response. This can only be structured-cloneable data.

@@ -49,7 +49,7 @@

IPool<Worker, Data, Response>

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

@@ -66,6 +66,7 @@ numberOfWorkers opts promiseResponseMap +startTimestamp workerChoiceStrategyContext workerNodes

@@ -77,6 +78,7 @@ maxSize minSize type +utilization worker

@@ -92,7 +94,8 @@ checkValidTasksQueueOptions checkValidWorkerChoiceStrategy checkValidWorkerChoiceStrategyOptions -chooseWorkerNode +chooseWorkerNode +createAndSetupDynamicWorker createAndSetupWorker createWorker dequeueTask @@ -104,24 +107,29 @@ executeTask flushTasksQueue flushTasksQueues +getWorkerById +getWorkerInfo getWorkerNodeKey +handleTaskExecutionResponse +handleWorkerStartedMessage internalBusy isMain pushWorkerNode -registerWorkerMessageListener +redistributeQueuedTasks +registerWorkerMessageListener removeWorkerNode sendToWorker setTasksQueueOptions setWorkerChoiceStrategy setWorkerChoiceStrategyOptions -setWorkerNode -setWorkerNodeTasksUsage setWorkerStatistics setupHook +shallCreateDynamicWorker tasksQueueSize -updateEluTasksUsage -updateRunTimeTasksUsage -updateWaitTimeTasksUsage +updateEluWorkerUsage +updateRunTimeWorkerUsage +updateTaskStatisticsWorkerUsage +updateWaitTimeWorkerUsage workerListener

@@ -137,7 +145,7 @@

Type Parameters

-
Worker extends IWorker<Worker>

Worker extends IWorker

Data = unknown
@@ -163,7 +171,7 @@
Returns AbstractPool<Worker, Data, Response>
- Defined in src/pools/abstract-pool.ts:81

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

Properties

@@ -181,7 +189,7 @@

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

`Protected` `Readonly` filePath

filePath: string

@@ -189,7 +197,7 @@

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

`Protected` `Readonly` numberOfWorkers

numberOfWorkers: number

@@ -197,7 +205,7 @@

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

`Protected` `Readonly` opts

opts: PoolOptions<Worker>

@@ -205,7 +213,7 @@

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

`Protected` promiseResponseMap

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

@@ -218,25 +226,32 @@

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

`Private` `Readonly` startTimestamp

startTimestamp: number

The start timestamp of the pool.

`Protected` workerChoiceStrategyContext

workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>

Worker choice strategy context referencing a worker choice algorithm implementation.

Default to a round robin algorithm.

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

`Readonly` workerNodes

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

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

Pool worker nodes.

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

Accessors

@@ -250,7 +265,7 @@

Returns boolean

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

`Protected` full

Returns boolean

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

info

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

`Protected` `Abstract` maxSize

Returns number

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

`Protected` `Abstract` minSize

Returns number

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

`Protected` `Abstract` type

Returns "fixed" | "dynamic"

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

`Private` utilization

get utilization(): number
+
Gets the approximate pool utilization.
+
+
Returns number
The pool utilization.
+ +
+
- Defined in src/pools/abstract-pool.ts:389

`Protected` `Abstract` worker

Returns "cluster" | "thread"

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

Methods

@@ -339,21 +366,21 @@ Can be overridden.

message: MessageValue<Response, Worker | MessagePort>

message: MessageValue<Response, unknown>

The received message.

Returns void

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

`Protected` `Abstract` afterWorkerSetup

`Protected` afterWorkerSetup

afterWorkerSetup(worker): void
-
Function that can be hooked up when a worker has been newly created and moved to the pool worker nodes.
-
Can be used to update the maxListeners or binding the main-worker<->worker connection if not bind by default.
+
Function that can be hooked up when a worker has been newly created and moved to the pool worker nodes. +Can be overridden.
Parameters
@@ -366,11 +393,11 @@ Can be overridden.

Returns void
- Defined in src/pools/abstract-pool.ts:611

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

`Protected` beforeTaskExecutionHook

beforeTaskExecutionHook(workerNodeKey): void
beforeTaskExecutionHook(workerNodeKey, task): void
Hook executed before the worker task execution. Can be overridden.
@@ -382,11 +409,16 @@ Can be overridden.

workerNodeKey: number

The worker node key.

+
+
task: Task<Data>
+
The task to execute.
+

Returns void

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

`Private` buildTasksQueueOptions

tasksQueueOptions: TasksQueueOptions

Returns TasksQueueOptions

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

`Private` checkAndEmitEvents

Returns void
- Defined in src/pools/abstract-pool.ts:687

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

`Private` checkFilePath

filePath: string

Returns void

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

`Private` checkNumberOfWorkers

numberOfWorkers: number

Returns void

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

`Private` checkPoolOptions

opts: PoolOptions<Worker>

Returns void

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

`Private` checkValidTasksQueueOptions

tasksQueueOptions: TasksQueueOptions

Returns void

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

`Private` checkValidWorkerChoiceStrategy

Parameters

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

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

Returns void

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

`Private` checkValidWorkerChoiceStrategyOptions

workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

Returns void

`Protected` chooseWorkerNode

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

`Private` chooseWorkerNode

chooseWorkerNode(): number
Chooses a worker node for the next task.
-
The default worker choice strategy uses a round robin algorithm to distribute the load.
+
The default worker choice strategy uses a round robin algorithm to distribute the tasks.

Returns number
The worker node key
- Defined in src/pools/abstract-pool.ts:554

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

`Protected` createAndSetupDynamicWorker

createAndSetupDynamicWorker(): Worker
+
Creates a new dynamic worker and sets it up completely in the pool worker nodes.
+
+
Returns Worker
New, completely set up dynamic worker.
+ +
+
- Defined in src/pools/abstract-pool.ts:942

`Protected` createAndSetupWorker

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

`Protected` `Abstract` createWorker

createWorker(): Worker
-
Returns a newly created worker.
+
Creates a new worker.

-
Returns Worker
+
Returns Worker
Newly created worker.
+
- Defined in src/pools/abstract-pool.ts:602

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

`Private` dequeueTask

workerNodeKey: number

Returns undefined | Task<Data>

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

destroy

destroy(): Promise<void>
-
Shutdowns every current worker in this pool.
+
Terminates every current worker in this pool.

Returns Promise<void>
Implementation of IPool.destroy
- Defined in src/pools/abstract-pool.ts:418

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

`Protected` `Abstract` destroyWorker

destroyWorker(worker): void | Promise<void>
-
Shutdowns the given worker.
+
Terminates the given worker.
Parameters
@@ -565,7 +610,7 @@ Can be overridden.

Returns void | Promise<void>
- Defined in src/pools/abstract-pool.ts:433

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

enableTasksQueue

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

`Private` enqueueTask

task: Task<Data>

Returns number

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

execute

Optional data: Data
-
The task input data for the specified worker function. This can only be serializable data.
+
The task input data for the specified worker function. This can only be structured-cloneable data.
@@ -631,7 +676,7 @@ Can be overridden.
Implementation of IPool.execute
- Defined in src/pools/abstract-pool.ts:383

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

`Private` executeTask

task: Task<Data>

Returns void

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

`Private` flushTasksQueue

workerNodeKey: number

Returns void

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

`Private` flushTasksQueues

Returns void
- Defined in src/pools/abstract-pool.ts:800

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

`Private` getWorkerById

getWorkerById(workerId): undefined | Worker
+
Get the worker given its id.
+
+
+
Parameters
+
- +
  workerId: number
  +
  The worker id.
  +
  +
+
Returns undefined | Worker
The worker if found in the pool worker nodes, undefined otherwise.
+ +
+
- Defined in src/pools/abstract-pool.ts:433

`Private` getWorkerInfo

getWorkerInfo(workerNodeKey): WorkerInfo
+
Gets the worker information.
+
+
+
Parameters
+
- +
  workerNodeKey: number
  +
  The worker node key.
  +
  +
+
Returns WorkerInfo
+
+
- Defined in src/pools/abstract-pool.ts:1038

`Private` getWorkerNodeKey

The worker.

Returns number

The worker node key if the worker is found in the pool worker nodes, -1 otherwise.

Returns number

The worker node key if found in the pool worker nodes, -1 otherwise.

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

`Private` handleTaskExecutionResponse

handleTaskExecutionResponse(message): void
+
+
Parameters
+
- +
  message: MessageValue<Response, unknown>
+
Returns void
+
- Defined in src/pools/abstract-pool.ts:995

`Private` handleWorkerStartedMessage

handleWorkerStartedMessage(message): void
+
+
Parameters
+
- +
  message: MessageValue<Response, unknown>
+
Returns void
+
- Defined in src/pools/abstract-pool.ts:981

`Protected` internalBusy

internalBusy(): boolean
-
Returns boolean
+
Whether worker nodes are executing at least one task.
+
+
Returns boolean
Worker nodes busyness boolean status.
+ +
- Defined in src/pools/abstract-pool.ts:374

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

`Protected` `Abstract` isMain

Returns boolean

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

`Private` pushWorkerNode

`Protected` `Abstract` registerWorkerMessageListener

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

`Private` redistributeQueuedTasks

redistributeQueuedTasks(worker): void
+
+
Parameters
+
- +
  worker: Worker
+
Returns void
+
- Defined in src/pools/abstract-pool.ts:909

`Private` registerWorkerMessageListener

registerWorkerMessageListener<Message>(worker, listener): void
Registers a listener callback on the given worker.
@@ -761,12 +888,12 @@ Can be overridden.

Parameters
- -
  message: MessageValue<Message, Worker | MessagePort>
+
message: MessageValue<Message, unknown>

Returns void

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

`Private` removeWorkerNode

Returns void

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

`Protected` `Abstract` sendToWorker

-
message: MessageValue<Data, Worker | MessagePort>
+
message: MessageValue<Data, unknown>

The message.

Returns void

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

setTasksQueueOptions

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

setWorkerChoiceStrategy

Parameters

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

The worker choice strategy.

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

setWorkerChoiceStrategyOptions

`Private` setWorkerNode

setWorkerNode(workerNodeKey, worker, tasksUsage, tasksQueue): void
-
Sets the given worker in the pool worker nodes.
-
-
-
Parameters
-
- -
  workerNodeKey: number
  -
  The worker node key.
  -
  -
- -
  worker: Worker
  -
  The worker.
  -
  -
- -
  tasksUsage: TasksUsage
  -
  The worker tasks usage.
  -
  -
- -
  tasksQueue: Queue<Task<Data>>
  -
  The worker task queue.
  -
  -
-
Returns void
-
-
- Defined in src/pools/abstract-pool.ts:746

`Private` setWorkerNodeTasksUsage

setWorkerNodeTasksUsage(workerNode, tasksUsage): void
-
Sets the given worker node its tasks usage in the pool.
-
-
-
Parameters
-
- -
  workerNode: WorkerNode<Worker, Data>
  -
  The worker node.
  -
  -
- -
  tasksUsage: TasksUsage
  -
  The worker node tasks usage.
  -
  -
-
Returns void
-
-
- Defined in src/pools/abstract-pool.ts:704

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

`Private` setWorkerStatistics

worker: Worker

Returns void

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

`Protected` setupHook

setupHook(): void
-
Setup hook to execute code before worker node are created in the abstract constructor. -Can be overridden
+
Setup hook to execute code before worker nodes are created in the abstract constructor. +Can be overridden.

Returns void
- Defined in src/pools/abstract-pool.ts:441

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

`Private` shallCreateDynamicWorker

shallCreateDynamicWorker(): boolean
+
Conditions for dynamic worker creation.
+
+
Returns boolean
Whether to create a dynamic worker or not.
+ +
+
- Defined in src/pools/abstract-pool.ts:823

`Private` tasksQueueSize

workerNodeKey: number

Returns number

`Private` updateEluTasksUsage

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

`Private` updateEluWorkerUsage

updateEluWorkerUsage(workerUsage, message): void
+
+
Parameters
+
- +
  workerUsage: WorkerUsage
- +
  message: MessageValue<Response, unknown>
+
Returns void
+
- Defined in src/pools/abstract-pool.ts:735

`Private` updateRunTimeWorkerUsage

updateEluTasksUsage(workerTasksUsage, message): void
updateRunTimeWorkerUsage(workerUsage, message): void
Parameters
- -
  workerTasksUsage: TasksUsage
- -
  message: MessageValue<Response, Worker | MessagePort>
+
message: MessageValue<Response, unknown>

Returns void

`Private` updateRunTimeTasksUsage

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

`Private` updateTaskStatisticsWorkerUsage

updateRunTimeTasksUsage(workerTasksUsage, message): void
updateTaskStatisticsWorkerUsage(workerUsage, message): void
Parameters
- -
  workerTasksUsage: TasksUsage
- -
  message: MessageValue<Response, Worker | MessagePort>
+
message: MessageValue<Response, unknown>

Returns void

`Private` updateWaitTimeTasksUsage

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

`Private` updateWaitTimeWorkerUsage

updateWaitTimeTasksUsage(workerTasksUsage, message): void
updateWaitTimeWorkerUsage(workerUsage, task): void
Parameters
- -
  workerTasksUsage: TasksUsage
- -
  message: MessageValue<Response, Worker | MessagePort>
+
task: Task<Data>

Returns void

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

`Protected` workerListener

Parameters

-
message: MessageValue<Response, Worker | MessagePort>

message: MessageValue<Response, unknown>

Returns void

The listener function to execute when a message is received from a worker.

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

WorkerTypes

availableParallelism

Generated using TypeDoc

\ No newline at end of file