X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=2377e5ef16fdc1a416ee8a3b6d1c857875680190;hb=396360a789e4806699533ddf899c79dc2b7ae868;hp=adb04610252b659ce602b18ff09a5772222da20f;hpb=6c525543a7ed67a926b7c1f4bf98985aaad1f088;p=poolifier.git
diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html
index adb04610..2377e5ef 100644
--- a/docs/classes/AbstractPool.html
+++ b/docs/classes/AbstractPool.html
@@ -1,4 +1,4 @@
-
AbstractPool | poolifier
+AbstractPool | poolifier
@@ -18,34 +18,34 @@
-
+
Type Parameters
-
+
-
-
Worker extends IWorker
+Worker extends IWorker
-
-
Data = unknown
+Data = unknown
-
-
Response = unknown
-
Returns number
-
+
execute
-
-- execute(data: Data): Promise<Response>
+
+- execute(data?): Promise<Response>
-
-
Returns void
-
+
Private
flushTasksQueueByWorker
-
-- flushTasksQueueByWorker(worker: Worker): void
+
+- flushTasksQueueByWorker(worker): void
-
+
worker: Worker
+
Returns void
+
+Private
flushTasksQueues
+
+- flushTasksQueues(): void
+-
Returns void
-
+
Private
getWorkerNodeKey
-
-- getWorkerNodeKey(worker: Worker): number
+
+- getWorkerNodeKey(worker): number
-
Parameters
-
-
worker: Worker
+worker: Worker
-Returns number
-
+
Private
getWorkerTasksUsage
-
-- getWorkerTasksUsage(worker: Worker): undefined | TasksUsage
+
+- getWorkerTasksUsage(worker): TasksUsage
-
Parameters
-
-
worker: Worker
+worker: Worker
-Returns undefined | TasksUsage
-
+
Protected
internalBusy
-
-- internalBusy(): boolean
+
+- internalBusy(): boolean
-
Returns boolean
-
+
Protected
Abstract
isMain
-
-- isMain(): boolean
+
+- isMain(): boolean
-
Returns boolean
-
+
Private
pushWorkerNode
-
-- pushWorkerNode(worker: Worker): number
+
+- pushWorkerNode(worker): number
-
Parameters
-
-
worker: Worker
+worker: Worker
-Returns number
-
+
Protected
Abstract
registerWorkerMessageListener
-
-- registerWorkerMessageListener<Message>(worker: Worker, listener: ((message: MessageValue<Message, unknown>) => void)): void
+
+- registerWorkerMessageListener<Message>(worker, listener): void
-
-
Parameters
-
-
worker: Worker
+worker: Worker
-
-
listener: ((message: MessageValue<Message, unknown>) => void)
+listener: ((message) => void)
Returns void
Returns void
-
+
Private
removeWorkerNode
-
-- removeWorkerNode(worker: Worker): void
+
+- removeWorkerNode(worker): void
-
@@ -678,16 +718,16 @@ Can be overridden.
Parameters
-
-
worker: Worker
+worker: Worker
Returns void
-
+
Protected
Abstract
sendToWorker
-
-- sendToWorker(worker: Worker, message: MessageValue<Data, unknown>): void
+
+- sendToWorker(worker, message): void
-
@@ -695,20 +735,38 @@ Can be overridden.
Parameters
-
-
worker: Worker
+worker: Worker
-
-
+
Returns void
-
+
+setTasksQueueOptions
+
+- setTasksQueueOptions(tasksQueueOptions): void
+-
+
+
+
Returns void
+
setWorkerChoiceStrategy
-
-- setWorkerChoiceStrategy(workerChoiceStrategy: "ROUND_ROBIN" | "LESS_USED" | "LESS_BUSY" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN"): void
+
+- setWorkerChoiceStrategy(workerChoiceStrategy, workerChoiceStrategyOptions?): void
-
@@ -716,17 +774,39 @@ Can be overridden.
Parameters
-
-
workerChoiceStrategy: "ROUND_ROBIN" | "LESS_USED" | "LESS_BUSY" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN"
+workerChoiceStrategy: "ROUND_ROBIN" | "LESS_USED" | "LESS_BUSY" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN"
+-
+
+
+Returns void
+
+setWorkerChoiceStrategyOptions
+
+- setWorkerChoiceStrategyOptions(workerChoiceStrategyOptions): void
+-
+
+
Returns void
-
+
Private
setWorkerNode
-
-- setWorkerNode(workerNodeKey: number, worker: Worker, tasksUsage: TasksUsage, tasksQueue: Task<Data>[]): void
+
+- setWorkerNode(workerNodeKey, worker, tasksUsage, tasksQueue): void
-
@@ -734,28 +814,28 @@ Can be overridden.
Parameters
-
-
workerNodeKey: number
+workerNodeKey: number
-
-
worker: Worker
+worker: Worker
-
-
tasksUsage: TasksUsage
+
-
-
tasksQueue: Task<Data>[]
+tasksQueue: Task<Data>[]
Returns void
-
+
Private
setWorkerNodeTasksUsage
-
-- setWorkerNodeTasksUsage(workerNode: WorkerNode<Worker, Data>, tasksUsage: TasksUsage): void
+
+- setWorkerNodeTasksUsage(workerNode, tasksUsage): void
-
@@ -763,67 +843,65 @@ Can be overridden.
Parameters
-
-
workerNode: WorkerNode<Worker, Data>
+workerNode: WorkerNode<Worker, Data>
-
-
tasksUsage: TasksUsage
+
Returns void
-
+
Protected
setupHook
-
-- setupHook(): void
+
+- setupHook(): void
-
Returns void
-
+
Private
tasksQueueSize
-
-- tasksQueueSize(workerNodeKey: number): number
+
+- tasksQueueSize(workerNodeKey): number
-
+
workerNodeKey: number
Returns number
-
+
Protected
workerListener
-
+Defined in src/pools/abstract-pool.ts:504
+Theme
On This Page
+constructor
+emitter
+filePath
+numberOfWorkers
+opts
+promiseResponseMap
+workerChoiceStrategyContext
+workerNodes
+busy
+full
+numberOfQueuedTasks
+numberOfRunningTasks
+type
+afterTaskExecutionHook
+afterWorkerSetup
+beforeTaskExecutionHook
+buildTasksQueueOptions
+checkAndEmitEvents
+checkFilePath
+checkNumberOfWorkers
+checkPoolOptions
+checkValidTasksQueueOptions
+checkValidWorkerChoiceStrategy
+chooseWorkerNode
+createAndSetupWorker
+createWorker
+dequeueTask
+destroy
+destroyWorker
+enableTasksQueue
+enqueueTask
+execute
+executeTask
+flushTasksQueue
+flushTasksQueueByWorker
+flushTasksQueues
+getWorkerNodeKey
+getWorkerTasksUsage
+internalBusy
+isMain
+pushWorkerNode
+registerWorkerMessageListener
+removeWorkerNode
+sendToWorker
+setTasksQueueOptions
+setWorkerChoiceStrategy
+setWorkerChoiceStrategyOptions
+setWorkerNode
+setWorkerNodeTasksUsage
+setupHook
+tasksQueueSize
+workerListener
+PoolType
+AbstractPool
+AbstractWorker
+CircularArray
+ClusterWorker
+DynamicClusterPool
+DynamicThreadPool
+FixedClusterPool
+FixedThreadPool
+PoolEmitter
+ThreadWorker
+WorkerChoiceStrategyContext
+ClusterPoolOptions
+IPool
+IWorker
+IWorkerChoiceStrategy
+MessageValue
+PoolOptions
+PromiseResponseWrapper
+RequiredStatistics
+Task
+TasksQueueOptions
+TasksUsage
+WorkerChoiceStrategyOptions
+WorkerNode
+WorkerOptions
+Draft
+ErrorHandler
+ExitHandler
+KillBehavior
+MessageHandler
+OnlineHandler
+PoolEvent
+ThreadWorkerWithMessageChannel
+WorkerAsyncFunction
+WorkerChoiceStrategy
+WorkerFunction
+WorkerSyncFunction
+KillBehaviors
+PoolEvents
+WorkerChoiceStrategies
\ No newline at end of file
Base class that implements some shared logic for all poolifier pools.