X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=60e3c607794b436d8df80a4558cc8b5d41771dd4;hb=1b27b0580ef80da95449c262682015a6da19e226;hp=86fada26adb28db38824ca5ecf87c2b5d236b18c;hpb=0b4e655ca22daa4e6efc10d4ef575520a3abfa2c;p=poolifier.git
diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html
index 86fada26..60e3c607 100644
--- a/docs/classes/AbstractPool.html
+++ b/docs/classes/AbstractPool.html
@@ -1,4 +1,4 @@
-
AbstractPool | poolifier - v2.6.45
+AbstractPool | poolifier - v3.0.5
@@ -49,7 +49,7 @@
IPool < Worker , Data , Response >
+
Defined in src/pools/abstract-pool.ts:66
@@ -87,7 +88,8 @@
Constructors
@@ -191,13 +203,14 @@
Returns AbstractPool < Worker , Data , Response >
+Defined in src/pools/abstract-pool.ts:128
Protected
Readonly
number Of Workers
number Of Workers : number
@@ -236,7 +249,7 @@
+Defined in src/pools/abstract-pool.ts:129
Protected
Readonly
opts
@@ -244,7 +257,7 @@
+Defined in src/pools/abstract-pool.ts:131
Protected
promise Response Map
@@ -257,7 +270,7 @@
+Defined in src/pools/abstract-pool.ts:89
Private
Readonly
start Timestamp
start Timestamp : number
@@ -265,7 +278,7 @@
+Defined in src/pools/abstract-pool.ts:119
Private
started
started : boolean
@@ -273,7 +286,7 @@
+Defined in src/pools/abstract-pool.ts:111
Private
starting
starting : boolean
@@ -281,7 +294,19 @@
+Defined in src/pools/abstract-pool.ts:115
+
+Private
Readonly
task Functions
+
+
+
Protected
worker Choice Strategy Context
@@ -289,7 +314,7 @@
+Defined in src/pools/abstract-pool.ts:95
Readonly
Internal
worker Nodes
@@ -298,7 +323,7 @@
+Defined in src/pools/abstract-pool.ts:72
Protected
full
@@ -324,7 +349,7 @@
Returns boolean
+Defined in src/pools/abstract-pool.ts:660
+Defined in src/pools/abstract-pool.ts:273
Protected
max Size
@@ -347,7 +372,7 @@
Returns number
+Defined in src/pools/abstract-pool.ts:486
Protected
min Size
@@ -358,7 +383,7 @@
Returns number
+Defined in src/pools/abstract-pool.ts:479
Private
ready
@@ -369,7 +394,7 @@
Returns boolean
+Defined in src/pools/abstract-pool.ts:431
Protected
Abstract
type
@@ -381,7 +406,7 @@
Returns "fixed" | "dynamic"
+Defined in src/pools/abstract-pool.ts:469
+Defined in src/pools/abstract-pool.ts:448
Protected
Abstract
worker
@@ -404,9 +429,40 @@
Returns "thread" | "cluster"
+Defined in src/pools/abstract-pool.ts:474
Protected
after Task Execution Hook
@@ -453,7 +509,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1043
Protected
after Worker Node Setup
@@ -473,7 +529,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1356
Protected
before Task Execution Hook
@@ -498,7 +554,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1013
Private
build Tasks Queue Options
@@ -511,7 +567,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:599
Private
check And Emit Dynamic Worker Creation Events
@@ -519,7 +575,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1594
Private
check And Emit Task Execution Events
@@ -527,7 +583,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1582
Private
check And Emit Task Queuing Events
@@ -535,35 +591,7 @@ Can be overridden.
Returns void
-
-Protected
check Dynamic Pool Size
-
-check Dynamic Pool Size ( min , max ) : void
-
-
-
Parameters
-
-
-min : number
-
-max : number
-Returns void
-
-Private
check File Path
-
-check File Path ( filePath ) : void
-
-
-Returns void
+Defined in src/pools/abstract-pool.ts:1588
Private
check Message Worker Id
+Defined in src/pools/abstract-pool.ts:496
Private
check Number Of Workers
@@ -597,7 +625,7 @@ Can be overridden.
numberOfWorkers : number
Returns void
+Defined in src/pools/abstract-pool.ts:172
Private
check Pool Options
@@ -610,33 +638,7 @@ Can be overridden.
Returns void
-
-Private
check Valid Tasks Queue Options
-
-check Valid Tasks Queue Options ( tasksQueueOptions ) : void
-
-
-Returns void
-
-Private
check Valid Worker Choice Strategy
-
-check Valid Worker Choice Strategy ( workerChoiceStrategy ) : void
-
-
-
Parameters
-
-
-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:190
Private
check Valid Worker Choice Strategy Options
@@ -649,7 +651,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:219
Private
choose Worker Node
@@ -662,7 +664,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1170
Protected
create And Setup Dynamic Worker Node
@@ -674,7 +676,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1260
Protected
create And Setup Worker Node
@@ -686,7 +688,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1216
Protected
Abstract
create Worker
@@ -698,7 +700,20 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1209
+
+Private
delete Task Function Worker Usages
+
+delete Task Function Worker Usages ( name ) : void
+
+
+Returns void
Private
dequeue Task
@@ -711,7 +726,47 @@ Can be overridden.
workerNodeKey : number
Returns undefined | Task < Data >
+Defined in src/pools/abstract-pool.ts:1688
+
+Protected
Abstract
deregister Worker Message Listener
+
+deregister Worker Message Listener < Message > ( workerNodeKey , listener ) : void
+
+
+
+
+
Parameters
+
+
+workerNodeKey : number
+
+
+
+listener : ( ( message ) => void )
+
+
+
+
+
+( message ) : void
+
+
+Returns void
+Returns void
+
+Defined in src/pools/abstract-pool.ts:949
Protected
Abstract
destroy Worker Node
@@ -742,7 +797,7 @@ Can be overridden.
Returns Promise < void >
+Defined in src/pools/abstract-pool.ts:989
+Defined in src/pools/abstract-pool.ts:564
Private
enqueue Task
@@ -782,7 +837,7 @@ Can be overridden.
task : Task < Data >
Returns number
+Defined in src/pools/abstract-pool.ts:1682
+Defined in src/pools/abstract-pool.ts:879
Private
execute Task
@@ -837,7 +892,20 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1676
+
+Protected
flag Worker Node As Not Ready
+
+flag Worker Node As Not Ready ( workerNodeKey ) : void
+
+
+Returns void
Protected
flush Tasks Queue
@@ -850,7 +918,7 @@ Can be overridden.
workerNodeKey : number
Returns void
+Defined in src/pools/abstract-pool.ts:1696
Private
flush Tasks Queues
@@ -858,7 +926,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1706
Protected
get Worker Info
@@ -878,7 +946,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1608
Private
get Worker Node Key By Worker
@@ -898,7 +966,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:512
Private
get Worker Node Key By Worker Id
@@ -910,7 +978,7 @@ Can be overridden.
Parameters
-workerId : number
+workerId : undefined | number
@@ -918,7 +986,33 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:524
+
+Private
Readonly
handle Back Pressure Event
+
+handle Back Pressure Event ( event ) : void
+
+
+Returns void
+
+Private
Readonly
handle Empty Queue Event
+
+handle Empty Queue Event ( event ) : void
+
+
+Returns void
Private
handle Task Execution Response
@@ -931,7 +1025,7 @@ Can be overridden.
message : MessageValue < Response , unknown >
Returns void
+Defined in src/pools/abstract-pool.ts:1554
Private
handle Worker Ready Response
@@ -944,7 +1038,7 @@ Can be overridden.
message : MessageValue < Response , unknown >
Returns void
+Defined in src/pools/abstract-pool.ts:1534
Private
has Back Pressure
@@ -952,7 +1046,28 @@ Can be overridden.
Returns boolean
+Defined in src/pools/abstract-pool.ts:1661
+
has Worker Node Back Pressure
+Defined in src/pools/abstract-pool.ts:1654
+
+Private
initialize Event Emitter
+
+initialize Event Emitter ( ) : void
+
+Returns void
Protected
internal Busy
@@ -985,7 +1108,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:676
Protected
Abstract
is Main
@@ -996,20 +1119,20 @@ Can be overridden.
Returns boolean
-
+
+Defined in src/pools/abstract-pool.ts:844
Private
redistribute Queued Tasks
@@ -1022,7 +1145,47 @@ Can be overridden.
workerNodeKey : number
Returns void
+Defined in src/pools/abstract-pool.ts:1406
+
+Protected
Abstract
register Once Worker Message Listener
+
+register Once Worker Message Listener < Message > ( workerNodeKey , listener ) : void
+
+
+
+
+
Parameters
+
+
+workerNodeKey : number
+
+
+
+listener : ( ( message ) => void )
+
+
+
+
+
+( message ) : void
+
+
+Returns void
+Returns void
+
Protected
Abstract
register Worker Message Listener
@@ -1062,7 +1225,28 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1317
+
Private
remove Worker Node
@@ -1081,22 +1265,20 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1641
Protected
send Kill Message To Worker
-send Kill Message To Worker ( workerNodeKey , workerId ) : Promise < void >
+send Kill Message To Worker ( workerNodeKey ) : Promise < void >
Parameters
-workerNodeKey : number
-
-workerId : number
+workerNodeKey : number
Returns Promise < void >
+Defined in src/pools/abstract-pool.ts:960
Protected
Abstract
send Startup Message To Worker
@@ -1115,7 +1297,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1387
Private
send Statistics Message To Worker
@@ -1134,7 +1316,35 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1394
+
+Private
send Task Function Operation To Worker
+
+send Task Function Operation To Worker ( workerNodeKey , message ) : Promise < boolean >
+
+
+
Parameters
+
+
+workerNodeKey : number
+
+
+Returns Promise < boolean >
+
+Private
send Task Function Operation To Workers
+
+send Task Function Operation To Workers ( message ) : Promise < boolean >
+
+
+Returns Promise < boolean >
Protected
Abstract
send To Worker
@@ -1163,7 +1373,36 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:1198
+
+set Default Task Function
+
+
+Private
set Task Stealing
+
+set Task Stealing ( ) : void
+
+Returns void
+Defined in src/pools/abstract-pool.ts:578
Private
set Tasks Queue Size
@@ -1196,7 +1435,15 @@ Can be overridden.
size : number
Returns void
+Defined in src/pools/abstract-pool.ts:613
+
+Private
set Tasks Stealing On Back Pressure
+
+set Tasks Stealing On Back Pressure ( ) : void
+
+Returns void
+Defined in src/pools/abstract-pool.ts:531
set Worker Choice Strategy Options
+Defined in src/pools/abstract-pool.ts:550
Protected
setup Hook
@@ -1253,7 +1500,7 @@ Can be overridden.
Returns void
+Defined in src/pools/abstract-pool.ts:997
Private
shall Create Dynamic Worker
@@ -1265,7 +1512,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1187
Private
shall Execute Task
@@ -1278,7 +1525,7 @@ Can be overridden.
workerNodeKey : number
Returns boolean
+Defined in src/pools/abstract-pool.ts:870
Private
shall Update Task Function Worker Usage
@@ -1298,7 +1545,7 @@ Can be overridden.
+Defined in src/pools/abstract-pool.ts:1076
-
-Private
task Stealing On Empty Queue
-
-task Stealing On Empty Queue ( workerId ) : void
-
-
-Returns void
+Defined in src/pools/abstract-pool.ts:933
Private
tasks Queue Size
@@ -1336,20 +1570,23 @@ Can be overridden.
workerNodeKey : number
Returns number
-
+
+Private
unset Task Stealing
-tasks Stealing On Back Pressure ( workerId ) : void
+unset Task Stealing ( ) : void
+
+Returns void
+
+Private
unset Tasks Stealing On Back Pressure
+
+unset Tasks Stealing On Back Pressure ( ) : void
-
Returns void
+Defined in src/pools/abstract-pool.ts:646
Private
update Elu Worker Usage
@@ -1364,7 +1601,7 @@ Can be overridden.
message : MessageValue < Response , unknown >
Returns void
+Defined in src/pools/abstract-pool.ts:1130
Private
update Run Time Worker Usage
@@ -1379,7 +1616,7 @@ Can be overridden.
message : MessageValue < Response , unknown >
Returns void
+Defined in src/pools/abstract-pool.ts:1103
Private
update Task Statistics Worker Usage
@@ -1394,7 +1631,7 @@ Can be overridden.
message : MessageValue < Response , unknown >
Returns void
+Defined in src/pools/abstract-pool.ts:1085
Private
update Task Stolen Statistics Worker Usage
@@ -1409,7 +1646,7 @@ Can be overridden.
taskName : string
Returns void
+Defined in src/pools/abstract-pool.ts:1427
Private
update Wait Time Worker Usage
@@ -1424,34 +1661,23 @@ Can be overridden.
task : Task < Data >
Returns void
-
+
+Protected
worker Message Listener
@@ -1481,6 +1707,7 @@ Can be overridden.
start Timestamp
started
starting
+task Functions
worker Choice Strategy Context
worker Nodes
busy
@@ -1492,6 +1719,7 @@ Can be overridden.
type
utilization
worker
+add Task Function
add Worker Node
after Task Execution Hook
after Worker Node Setup
@@ -1500,46 +1728,56 @@ Can be overridden.
check And Emit Dynamic Worker Creation Events
check And Emit Task Execution Events
check And Emit Task Queuing Events
-check Dynamic Pool Size
-check File Path
check Message Worker Id
check Number Of Workers
check Pool Options
-check Valid Tasks Queue Options
-check Valid Worker Choice Strategy
check Valid Worker Choice Strategy Options
choose Worker Node
create And Setup Dynamic Worker Node
create And Setup Worker Node
create Worker
+delete Task Function Worker Usages
dequeue Task
+deregister Worker Message Listener
destroy
destroy Worker Node
enable Tasks Queue
enqueue Task
execute
execute Task
+flag Worker Node As Not Ready
flush Tasks Queue
flush Tasks Queues
get Worker Info
get Worker Node Key By Worker
get Worker Node Key By Worker Id
+handle Back Pressure Event
+handle Empty Queue Event
handle Task Execution Response
handle Worker Ready Response
has Back Pressure
+has Task Function
has Worker Node Back Pressure
+initialize Event Emitter
internal Busy
is Main
-list Task Functions
+list Task Function Names
redistribute Queued Tasks
+register Once Worker Message Listener
register Worker Message Listener
+remove Task Function
remove Worker Node
send Kill Message To Worker
send Startup Message To Worker
send Statistics Message To Worker
+send Task Function Operation To Worker
+send Task Function Operation To Workers
send To Worker
+set Default Task Function
+set Task Stealing
set Tasks Queue Options
set Tasks Queue Size
+set Tasks Stealing On Back Pressure
set Worker Choice Strategy
set Worker Choice Strategy Options
setup Hook
@@ -1547,17 +1785,17 @@ Can be overridden.
shall Execute Task
shall Update Task Function Worker Usage
start
-task Stealing On Empty Queue
tasks Queue Size
-tasks Stealing On Back Pressure
+unset Task Stealing
+unset Tasks Stealing On Back Pressure
update Elu Worker Usage
update Run Time Worker Usage
update Task Statistics Worker Usage
update Task Stolen Statistics Worker Usage
update Wait Time Worker Usage
-worker Listener
+worker Message Listener
-
\ No newline at end of file
+
\ No newline at end of file
Emitter on which events can be listened to.
+
+Optional
emitterEvent emitter integrated with async resource on which events can be listened to. +The async tracking tooling identifier is
poolifier:<PoolType>-<WorkerType>-pool
.Events that can currently be listened to:
'ready'
: Emitted when the number of workers created in the pool has reached the minimum size expected and are ready.Protected
Readonly
fileProtected
Optional
Readonly
max