@@ -45,7 +45,7 @@
+
Defined in src/pools/thread/fixed.ts:35
+
Defined in src/pools/thread/fixed.ts:46
Properties
@@ -158,12 +159,13 @@
'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).
+
Defined in src/pools/abstract-pool.ts:65
Protected
Readonly
filePath
filePath: string
@@ -172,7 +174,7 @@
+
Defined in src/pools/abstract-pool.ts:105
Protected
Readonly
numberOfWorkers
numberOfWorkers: number
@@ -181,7 +183,7 @@
+
Defined in src/pools/abstract-pool.ts:104
Protected
Readonly
opts
@@ -190,7 +192,7 @@
+
Defined in src/pools/thread/fixed.ts:49
Protected
promiseResponseMap
@@ -204,7 +206,7 @@
+
Defined in src/pools/abstract-pool.ts:75
Protected
workerChoiceStrategyContext
@@ -213,16 +215,16 @@
+
Defined in src/pools/abstract-pool.ts:81
-Readonly
workerNodes
+Readonly
Internal
workerNodes
+
Defined in src/pools/abstract-pool.ts:62
+
Defined in src/pools/abstract-pool.ts:631
+
Defined in src/pools/abstract-pool.ts:321
+
Defined in src/pools/thread/fixed.ts:137
+
Defined in src/pools/thread/fixed.ts:132
+
Defined in src/pools/abstract-pool.ts:464
+
Defined in src/pools/thread/fixed.ts:122
+
Defined in src/pools/abstract-pool.ts:481
+
Defined in src/pools/thread/fixed.ts:127
Protected
afterWorkerNodeSetup
+
Defined in src/pools/abstract-pool.ts:1081
Protected
beforeTaskExecutionHook
+
Defined in src/pools/abstract-pool.ts:795
Protected
checkDynamicPoolSize
+
Defined in src/pools/abstract-pool.ts:176
Protected
createAndSetupDynamicWorkerNode
+
Defined in src/pools/abstract-pool.ts:1028
Protected
createAndSetupWorkerNode
+
Defined in src/pools/abstract-pool.ts:988
+
Defined in src/pools/thread/fixed.ts:114
+
Defined in src/pools/abstract-pool.ts:741
Protected
destroyWorkerNode
+
Defined in src/pools/thread/fixed.ts:60
+
Defined in src/pools/abstract-pool.ts:596
+
Defined in src/pools/abstract-pool.ts:681
Protected
flushTasksQueue
+
Defined in src/pools/abstract-pool.ts:1327
+
Defined in src/pools/abstract-pool.ts:1241
+
+hasWorkerNodeBackPressure
+
+
Defined in src/pools/abstract-pool.ts:647
+
Defined in src/pools/thread/fixed.ts:55
+
Defined in src/pools/abstract-pool.ts:668
Protected
registerWorkerMessageListener
+
Defined in src/pools/thread/fixed.ts:104
Protected
sendKillMessageToWorker
+
Defined in src/pools/abstract-pool.ts:750
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:608
+
Defined in src/pools/abstract-pool.ts:563
setWorkerChoiceStrategyOptions
+
Defined in src/pools/abstract-pool.ts:582
+
Defined in src/pools/abstract-pool.ts:779
+
Pool worker nodes.