X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=c42a10b2a6673c0f72470a7367e64a022e380d5f;hb=1ed7fb6c99f2fcb5f319d9c1fa2aefc5434f82e4;hp=2fe2f7cd195f2bbd6499945eb63d4dad225ffc0c;hpb=0676e5d32c8f8ee5c5b7f5998f4973b0a276460f;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 2fe2f7cd..c42a10b2 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,13 +1,13 @@ -AbstractPool | poolifier - v2.6.30
+AbstractPool | poolifier - v3.0.2
-
+
  • The search index is not available
  • poolifier - v3.0.2 +
    @@ -49,32 +49,34 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:65
  • - +

    Constructors

    -

    Properties

    -

    Accessors

    -
    busy +
    busy full info maxSize @@ -86,7 +88,8 @@

    Methods

    -
    addWorkerNode +
    addTaskFunction +addWorkerNode afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook @@ -94,62 +97,77 @@ checkAndEmitDynamicWorkerCreationEvents checkAndEmitTaskExecutionEvents checkAndEmitTaskQueuingEvents -checkDynamicPoolSize -checkFilePath checkMessageWorkerId checkNumberOfWorkers checkPoolOptions -checkValidTasksQueueOptions -checkValidWorkerChoiceStrategy checkValidWorkerChoiceStrategyOptions chooseWorkerNode createAndSetupDynamicWorkerNode createAndSetupWorkerNode createWorker +deleteTaskFunctionWorkerUsages dequeueTask +deregisterWorkerMessageListener destroy destroyWorkerNode enableTasksQueue enqueueTask execute executeTask +flagWorkerNodeAsNotReady flushTasksQueue flushTasksQueues getWorkerInfo getWorkerNodeKeyByWorker getWorkerNodeKeyByWorkerId +handleBackPressureEvent +handleEmptyQueueEvent handleTaskExecutionResponse handleWorkerReadyResponse hasBackPressure +hasTaskFunction hasWorkerNodeBackPressure +initializeEventEmitter internalBusy isMain -listTaskFunctions +listTaskFunctionNames redistributeQueuedTasks +registerOnceWorkerMessageListener registerWorkerMessageListener +removeTaskFunction removeWorkerNode sendKillMessageToWorker sendStartupMessageToWorker sendStatisticsMessageToWorker +sendTaskFunctionOperationToWorker +sendTaskFunctionOperationToWorkers sendToWorker +setDefaultTaskFunction +setTaskStealing setTasksQueueOptions +setTasksQueueSize +setTasksStealingOnBackPressure setWorkerChoiceStrategy setWorkerChoiceStrategyOptions setupHook shallCreateDynamicWorker +shallExecuteTask shallUpdateTaskFunctionWorkerUsage -startPool +start tasksQueueSize +unsetTaskStealing +unsetTasksStealingOnBackPressure updateEluWorkerUsage updateRunTimeWorkerUsage updateTaskStatisticsWorkerUsage +updateTaskStolenStatisticsWorkerUsage updateWaitTimeWorkerUsage -workerListener +workerMessageListener

    Constructors

    - +
    +
  • Defined in src/pools/abstract-pool.ts:127
  • Properties

    - -
    emitter?: PoolEmitter
    -

    Emitter on which events can be listened to.

    + +
    emitter?: EventEmitterAsyncResource
    +

    Event 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.
    • -
    • 'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing at least one task.
    • +
    • 'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing concurrently their tasks quota.
    • '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.
    • +
    • '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).
    • +
    • 'backPressure': Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size >= maximum queue size).
    +
  • Defined in src/pools/abstract-pool.ts:74
  • filePath: string
    @@ -214,7 +233,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:129
  • max?: number
    @@ -222,7 +241,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:79
  • numberOfWorkers: number
    @@ -230,7 +249,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:128
  • opts: PoolOptions<Worker>
    @@ -238,11 +257,11 @@
    +
  • Defined in src/pools/abstract-pool.ts:130
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    -

    The task execution response promise map.

    +

    The task execution response promise map:

    • key: The message id of each submitted task.
    • value: An object that contains the worker, the execution response promise resolve and reject callbacks.
    • @@ -251,7 +270,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:88
  • startTimestamp: number
    @@ -259,15 +278,35 @@
    +
  • Defined in src/pools/abstract-pool.ts:118
  • +
    + +
    started: boolean
    +

    Whether the pool is started or not.

    +
    +
    - +
    starting: boolean

    Whether the pool is starting or not.

    +
  • Defined in src/pools/abstract-pool.ts:114
  • +
    + +
    taskFunctions: Map<string, TaskFunction<Data, Response>>
    +

    The task functions added at runtime map:

    + +
    +
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -275,7 +314,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:94
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -284,7 +323,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:71
  • Accessors

    @@ -298,7 +337,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:671
  • +
  • Defined in src/pools/abstract-pool.ts:662
  • +
  • Defined in src/pools/abstract-pool.ts:272
  • +
  • Defined in src/pools/abstract-pool.ts:485
  • +
  • Defined in src/pools/abstract-pool.ts:478
  • +
  • Defined in src/pools/abstract-pool.ts:430
  • +
  • Defined in src/pools/abstract-pool.ts:468
  • +
  • Defined in src/pools/abstract-pool.ts:447
  • +
  • Defined in src/pools/abstract-pool.ts:473
  • Methods

    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1616
  • +
  • Defined in src/pools/abstract-pool.ts:1044
  • +
  • Defined in src/pools/abstract-pool.ts:1357
  • +
  • Defined in src/pools/abstract-pool.ts:1014
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:601
  • +
  • Defined in src/pools/abstract-pool.ts:1591
  • +
  • Defined in src/pools/abstract-pool.ts:1579
  • -
    - -
    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:1585
  • +
  • Defined in src/pools/abstract-pool.ts:495
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:171
  • Returns void

    -
    - -
    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:189
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:218
  • +
  • Defined in src/pools/abstract-pool.ts:1171
  • +
  • Defined in src/pools/abstract-pool.ts:1261
  • +
  • Defined in src/pools/abstract-pool.ts:1217
  • +
  • Defined in src/pools/abstract-pool.ts:1210
  • +
    + +

    Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1685
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:951
  • +
  • Defined in src/pools/abstract-pool.ts:990
  • +
  • Defined in src/pools/abstract-pool.ts:566
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1679
  • +
  • Defined in src/pools/abstract-pool.ts:881
  • +
  • Defined in src/pools/abstract-pool.ts:1673
  • +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1693
  • +
  • Defined in src/pools/abstract-pool.ts:1703
  • +
  • Defined in src/pools/abstract-pool.ts:1605
  • +
  • Defined in src/pools/abstract-pool.ts:514
  • +
  • Defined in src/pools/abstract-pool.ts:526
  • +
    + +
    +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1551
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1535
  • +
  • Defined in src/pools/abstract-pool.ts:1658
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1651
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:678
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:1005
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:846
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1407
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1318
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1638
  • Returns Promise<void>

    +
  • Defined in src/pools/abstract-pool.ts:962
  • +
  • Defined in src/pools/abstract-pool.ts:1388
  • +
  • Defined in src/pools/abstract-pool.ts:1395
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1199
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:580
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:533
  • +
  • Defined in src/pools/abstract-pool.ts:552
  • +
  • Defined in src/pools/abstract-pool.ts:998
  • +
  • Defined in src/pools/abstract-pool.ts:1188
  • +
    + +
    -
    - -
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:935
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1689
  • +
    + +
    +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1131
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1104
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1086
  • +
    + +

    Returns void

    -
    - +
  • Defined in src/pools/abstract-pool.ts:1118
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:1519
  • +
    -

    Generated using TypeDoc

    -
    \ No newline at end of file +

    Generated using TypeDoc

    +
    \ No newline at end of file