X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=d100e14889ec71c12977e9f0c175905c3351b81a;hb=c0eb19668d003c60eb90781a1c91f2743442ed83;hp=62d8a91710f7fa58fce920579e93287a45338ce2;hpb=fddf9cc424b3ace38fd414899c666c76a03c3aff;p=poolifier.git
diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html
index 62d8a917..d100e148 100644
--- a/docs/classes/AbstractPool.html
+++ b/docs/classes/AbstractPool.html
@@ -49,7 +49,7 @@
- IPool<Worker, Data, Response>
+Defined in src/pools/abstract-pool.ts:46
@@ -163,7 +167,7 @@
Returns AbstractPool<Worker, Data, Response>
+Defined in src/pools/abstract-pool.ts:86
Protected
Readonly
filePath
filePath: string
@@ -189,7 +193,7 @@
+Defined in src/pools/abstract-pool.ts:88
Protected
Readonly
numberOfWorkers
numberOfWorkers: number
@@ -197,7 +201,7 @@
+Defined in src/pools/abstract-pool.ts:87
Protected
Readonly
opts
@@ -205,7 +209,7 @@
+Defined in src/pools/abstract-pool.ts:89
Protected
promiseResponseMap
@@ -218,16 +222,15 @@
+Defined in src/pools/abstract-pool.ts:65
Protected
workerChoiceStrategyContext
+Defined in src/pools/abstract-pool.ts:73
Readonly
workerNodes
@@ -236,7 +239,7 @@
+Defined in src/pools/abstract-pool.ts:52
Protected
full
@@ -262,7 +265,7 @@
Returns boolean
+Defined in src/pools/abstract-pool.ts:391
+Defined in src/pools/abstract-pool.ts:240
Protected
Abstract
maxSize
@@ -285,7 +288,7 @@
Returns number
+Defined in src/pools/abstract-pool.ts:308
Protected
Abstract
minSize
@@ -296,7 +299,7 @@
Returns number
+Defined in src/pools/abstract-pool.ts:303
Protected
Abstract
type
@@ -308,7 +311,7 @@
Returns "fixed" | "dynamic"
+Defined in src/pools/abstract-pool.ts:293
Protected
Abstract
worker
@@ -319,7 +322,7 @@
Returns "cluster" | "thread"
+Defined in src/pools/abstract-pool.ts:298
Protected
Abstract
afterWorkerSetup
@@ -366,11 +369,11 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:696
Protected
beforeTaskExecutionHook
-- beforeTaskExecutionHook(workerNodeKey): void
+- beforeTaskExecutionHook(workerNodeKey, task): void
-
Returns void
+Defined in src/pools/abstract-pool.ts:489
Private
buildTasksQueueOptions
@@ -399,7 +407,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:378
Private
checkAndEmitEvents
@@ -407,7 +415,7 @@ Can be overridden.
-
Returns void
+Defined in src/pools/abstract-pool.ts:795
Private
checkFilePath
@@ -420,7 +428,7 @@ Can be overridden.
filePath: string
Returns void
+Defined in src/pools/abstract-pool.ts:123
Private
checkNumberOfWorkers
@@ -433,7 +441,7 @@ Can be overridden.
numberOfWorkers: number
Returns void
+Defined in src/pools/abstract-pool.ts:132
Private
checkPoolOptions
@@ -446,7 +454,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:150
Private
checkValidTasksQueueOptions
@@ -459,7 +467,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:215
Private
checkValidWorkerChoiceStrategy
@@ -469,10 +477,10 @@ Can be overridden.
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:177
Private
checkValidWorkerChoiceStrategyOptions
@@ -485,20 +493,32 @@ Can be overridden.
Returns void
-
-Protected
chooseWorkerNode
-
+
+Private
chooseWorkerNode
+
- chooseWorkerNode(): number
-
Returns number
The worker node key
+Defined in src/pools/abstract-pool.ts:640
+
+Protected
createAndSetupDynamicWorker
+
Protected
createAndSetupWorker
@@ -510,18 +530,19 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:703
Protected
Abstract
createWorker
- createWorker(): Worker
-
-
Returns undefined | Task<Data>
+Defined in src/pools/abstract-pool.ts:876
destroy
- destroy(): Promise<void>
-
-
Returns void
+Defined in src/pools/abstract-pool.ts:884
Private
flushTasksQueues
@@ -667,7 +688,20 @@ Can be overridden.
-
Returns void
+Defined in src/pools/abstract-pool.ts:895
+
+Private
getTaskStatistics
+
Private
getWorkerNodeKey
@@ -687,15 +721,32 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:316
+
+Private
getWorkerUsage
+
Protected
internalBusy
- internalBusy(): boolean
-
-
Returns boolean
+Defined in src/pools/abstract-pool.ts:407
Protected
Abstract
isMain
@@ -706,7 +757,7 @@ Can be overridden.
Returns boolean
+Defined in src/pools/abstract-pool.ts:480
Private
pushWorkerNode
@@ -726,7 +777,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:825
Protected
Abstract
registerWorkerMessageListener
@@ -761,12 +812,12 @@ Can be overridden.
Parameters
+message: MessageValue<Message, unknown, Worker | MessagePort>
Returns void
Returns void
+Defined in src/pools/abstract-pool.ts:678
Private
removeWorkerNode
@@ -785,7 +836,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:859
Protected
Abstract
sendToWorker
@@ -802,14 +853,14 @@ Can be overridden.
-
-
message: MessageValue<Data, Worker | MessagePort>
+message: MessageValue<Data, unknown, Worker | MessagePort>
Returns void
+Defined in src/pools/abstract-pool.ts:667
+Defined in src/pools/abstract-pool.ts:368
setWorkerChoiceStrategy
@@ -841,7 +892,7 @@ Can be overridden.
Parameters
+Defined in src/pools/abstract-pool.ts:323
setWorkerChoiceStrategyOptions
-
-Private
setWorkerNode
-
-- setWorkerNode(workerNodeKey, worker, tasksUsage, tasksQueue): void
--
-
-
-
Parameters
-
--
-
workerNodeKey: number
-
-
--
-
worker: Worker
-
-
--
-
-
-
--
-
tasksQueue: Queue<Task<Data>>
-
-
-Returns void
-
+Defined in src/pools/abstract-pool.ts:345
Private
setWorkerNodeTasksUsage
-- setWorkerNodeTasksUsage(workerNode, tasksUsage): void
+- setWorkerNodeTasksUsage(workerNode, workerUsage): void
-
@@ -925,14 +942,14 @@ Can be overridden.
-
-
-
Returns void
+Defined in src/pools/abstract-pool.ts:812
Private
setWorkerStatistics
@@ -945,7 +962,7 @@ Can be overridden.
worker: Worker
Returns void
+Defined in src/pools/abstract-pool.ts:901
Protected
setupHook
@@ -957,7 +974,19 @@ Can be overridden
Returns void
+Defined in src/pools/abstract-pool.ts:473
+
+Private
shallCreateDynamicWorker
+
Private
tasksQueueSize
@@ -970,52 +999,67 @@ Can be overridden
workerNodeKey: number
Returns number
-
+
+Private
updateEluWorkerUsage
+
+- updateEluWorkerUsage(workerUsage, message): void
+-
+
+
Parameters
+
+-
+
+-
+
message: MessageValue<Response, unknown, Worker | MessagePort>
+Returns void
+
+Private
updateRunTimeWorkerUsage
-- updateEluTasksUsage(workerTasksUsage, message): void
+- updateRunTimeWorkerUsage(workerUsage, message): void
-
+
message: MessageValue<Response, unknown, Worker | MessagePort>
Returns void
-
+
+Private
updateTaskStatisticsWorkerUsage
-- updateRunTimeTasksUsage(workerTasksUsage, message): void
+- updateTaskStatisticsWorkerUsage(workerUsage, message): void
-
+
message: MessageValue<Response, unknown, Worker | MessagePort>
Returns void
-
+
+Private
updateWaitTimeWorkerUsage
-- updateWaitTimeTasksUsage(workerTasksUsage, message): void
+- updateWaitTimeWorkerUsage(workerUsage, task): void
-
+
task: Task<Data>
Returns void
+Defined in src/pools/abstract-pool.ts:557
Protected
workerListener
@@ -1036,13 +1080,13 @@ Can be overridden
Parameters
+message: MessageValue<Response, unknown, Worker | MessagePort>
Returns void
The listener function to execute when a message is received from a worker.
+Defined in src/pools/abstract-pool.ts:763
Worker choice strategy context referencing a worker choice algorithm implementation.
-Default to a round robin algorithm.