@@ -45,7 +45,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/thread/dynamic.ts:15
@@ -59,7 +59,7 @@ When the maximum number of threads is reached and workers are busy, an event is
Properties
emitter?
filePath
-
max
+
max
numberOfWorkers
opts
promiseResponseMap
@@ -71,7 +71,7 @@ When the maximum number of threads is reached and workers are busy, an event is
busy
full
info
-
maxSize
+
maxSize
minSize
ready
type
@@ -93,9 +93,12 @@ When the maximum number of threads is reached and workers are busy, an event is
execute
flushTasksQueue
getWorkerInfo
+
hasWorkerNodeBackPressure
internalBusy
isMain
+
listTaskFunctions
registerWorkerMessageListener
+
sendKillMessageToWorker
sendStartupMessageToWorker
sendToWorker
setTasksQueueOptions
@@ -147,7 +150,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/thread/dynamic.ts:27
Properties
@@ -156,17 +159,19 @@ When the maximum number of threads is reached and workers are busy, an event is
+Defined in src/pools/abstract-pool.ts:65
Protected Readonly filePath
filePath: string
@@ -175,15 +180,16 @@ When the maximum number of threads is reached and workers are busy, an event is
-
+
Protected Readonly max
max: number
+
Defined in src/pools/thread/dynamic.ts:29
Protected Readonly numberOfWorkers
numberOfWorkers: number
@@ -192,7 +198,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/abstract-pool.ts:109
Protected Readonly opts
@@ -201,7 +207,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/thread/fixed.ts:49
Protected promiseResponseMap
@@ -215,7 +221,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/abstract-pool.ts:75
Protected workerChoiceStrategyContext
@@ -224,16 +230,16 @@ When the maximum number of threads is reached and workers are busy, an event is
+
Defined in src/pools/abstract-pool.ts:81
-Readonly workerNodes
+Readonly Internal workerNodes
+
Defined in src/pools/abstract-pool.ts:62
Accessors
@@ -248,7 +254,7 @@ When the maximum number of threads is reached and workers are busy, an event is
+Defined in src/pools/thread/dynamic.ts:43
+
Defined in src/pools/abstract-pool.ts:641
-
+
Protected maxSize
-
+
- get maxSize(): number
-
Returns number
+
Defined in src/pools/abstract-pool.ts:525
+
Defined in src/pools/abstract-pool.ts:518
+
Defined in src/pools/abstract-pool.ts:470
+
Defined in src/pools/thread/dynamic.ts:38
+
Defined in src/pools/abstract-pool.ts:487
+
Defined in src/pools/thread/fixed.ts:127
Protected afterWorkerNodeSetup
+
Defined in src/pools/abstract-pool.ts:1091
Protected beforeTaskExecutionHook
+
Defined in src/pools/abstract-pool.ts:804
Protected checkDynamicPoolSize
+
Defined in src/pools/abstract-pool.ts:179
Protected createAndSetupDynamicWorkerNode
+
Defined in src/pools/abstract-pool.ts:1037
Protected createAndSetupWorkerNode
+
Defined in src/pools/abstract-pool.ts:997
+
Defined in src/pools/thread/fixed.ts:114
+
Defined in src/pools/abstract-pool.ts:750
Protected destroyWorkerNode
+
Defined in src/pools/thread/fixed.ts:60
+
Defined in src/pools/abstract-pool.ts:606
+
Defined in src/pools/abstract-pool.ts:691
Protected flushTasksQueue
+
Defined in src/pools/abstract-pool.ts:1345
+
Defined in src/pools/abstract-pool.ts:1260
+
+hasWorkerNodeBackPressure
+
+
Defined in src/pools/abstract-pool.ts:657
+
Defined in src/pools/thread/fixed.ts:55
+
Protected registerWorkerMessageListener
+
Defined in src/pools/thread/fixed.ts:104
+
+Protected sendKillMessageToWorker
+
+- sendKillMessageToWorker(workerNodeKey, workerId): Promise<void>
+-
+
+
Parameters
+
+-
+
workerNodeKey: number
+-
+
workerId: number
Returns Promise<void>
Protected sendStartupMessageToWorker
+
Defined in src/pools/thread/fixed.ts:88
+
Defined in src/pools/thread/fixed.ts:77
+
Defined in src/pools/abstract-pool.ts:618
+
Defined in src/pools/abstract-pool.ts:573
setWorkerChoiceStrategyOptions
+
Defined in src/pools/abstract-pool.ts:592
+
Defined in src/pools/abstract-pool.ts:788
+
Defined in src/pools/abstract-pool.ts:1174
Emitter on which events can be listened to.
Events that can currently be listened to:
-- '
'full': Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected.'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.'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.'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).