X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=dec90f6fe56e23902d9003daa955bd2a224459db;hb=b6fea09e6a8174e664770741943cf08445066e2b;hp=925961b5b1ff0d5d09dc885ac9c7ca9a65577abb;hpb=c7e01b67847217903200f2453a4ffd4ba6bb191a;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 925961b5..dec90f6f 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,13 +1,13 @@ -AbstractPool | poolifier - v2.6.22
+AbstractPool | poolifier - v2.6.42
-
+
  • The search index is not available
  • poolifier - v2.6.42 +
    @@ -49,31 +49,33 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:59
  • - +

    Constructors

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

    @@ -186,17 +200,19 @@

    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.
    • +
    • '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.
    • '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 >= maximum queue size).
    +
  • Defined in src/pools/abstract-pool.ts:68
  • filePath: string
    @@ -204,7 +220,15 @@
    +
  • Defined in src/pools/abstract-pool.ts:117
  • +
    + +
    max?: number
    +

    Dynamic pool maximum size property placeholder.

    +
    +
    numberOfWorkers: number
    @@ -212,7 +236,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:116
  • opts: PoolOptions<Worker>
    @@ -220,7 +244,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:118
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    @@ -233,7 +257,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:78
  • startTimestamp: number
    @@ -241,7 +265,15 @@
    +
  • Defined in src/pools/abstract-pool.ts:106
  • +
    + +
    started: boolean
    +

    Whether the pool is started or not.

    +
    +
    starting: boolean
    @@ -249,7 +281,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:98
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -257,16 +289,16 @@
    +
  • Defined in src/pools/abstract-pool.ts:84
  • - +
    workerNodes: IWorkerNode<Worker, Data>[] = []

    Pool worker nodes.

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

    @@ -280,7 +312,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:698
  • +
  • Defined in src/pools/abstract-pool.ts:689
  • +
  • Defined in src/pools/abstract-pool.ts:350
  • - +
    +
  • Defined in src/pools/abstract-pool.ts:562
  • - +
    +
  • Defined in src/pools/abstract-pool.ts:555
  • +
  • Defined in src/pools/abstract-pool.ts:507
  • +
  • Defined in src/pools/abstract-pool.ts:545
  • +
  • Defined in src/pools/abstract-pool.ts:524
  • +
  • Defined in src/pools/abstract-pool.ts:550
  • Methods

    @@ -396,7 +428,7 @@

    Throws

    https://nodejs.org/api/errors.html#class-error If the added worker node is not found.

    +
  • Defined in src/pools/abstract-pool.ts:1418
  • +
  • Defined in src/pools/abstract-pool.ts:888
  • +
  • Defined in src/pools/abstract-pool.ts:1162
  • +
  • Defined in src/pools/abstract-pool.ts:858
  • Returns TasksQueueOptions

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

    Returns void

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

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

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:251
  • +
  • Defined in src/pools/abstract-pool.ts:1015
  • +
  • Defined in src/pools/abstract-pool.ts:1105
  • +
  • Defined in src/pools/abstract-pool.ts:1061
  • +
  • Defined in src/pools/abstract-pool.ts:1054
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1483
  • +
  • Defined in src/pools/abstract-pool.ts:803
  • +
  • Defined in src/pools/abstract-pool.ts:834
  • +
  • Defined in src/pools/abstract-pool.ts:643
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1477
  • +
  • Defined in src/pools/abstract-pool.ts:747
  • +
  • Defined in src/pools/abstract-pool.ts:1471
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1491
  • +
  • Defined in src/pools/abstract-pool.ts:1501
  • +
  • Defined in src/pools/abstract-pool.ts:1407
  • +
  • Defined in src/pools/abstract-pool.ts:591
  • +
  • Defined in src/pools/abstract-pool.ts:603
  • Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:1339
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:705
  • +
  • Defined in src/pools/abstract-pool.ts:849
  • +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1202
  • +
  • Defined in src/pools/abstract-pool.ts:1149
  • +
  • Defined in src/pools/abstract-pool.ts:1440
  • +
    + +
    -
    - -
    +
    + +

    Returns void

    -
    - -
    +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1043
  • +
  • Defined in src/pools/abstract-pool.ts:655
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:610
  • +
  • Defined in src/pools/abstract-pool.ts:629
  • +
  • Defined in src/pools/abstract-pool.ts:842
  • +
  • Defined in src/pools/abstract-pool.ts:1032
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:337
  • +
    + +

    Returns number

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

    Returns void

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

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

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:962
  • +
  • Defined in src/pools/abstract-pool.ts:1321
  • @@ -1268,10 +1470,12 @@ Can be overridden.

  • constructor
  • emitter
  • filePath
  • +
  • max
  • numberOfWorkers
  • opts
  • promiseResponseMap
  • startTimestamp
  • +
  • started
  • starting
  • workerChoiceStrategyContext
  • workerNodes
  • @@ -1289,7 +1493,9 @@ Can be overridden.

  • afterWorkerNodeSetup
  • beforeTaskExecutionHook
  • buildTasksQueueOptions
  • -
  • checkAndEmitEvents
  • +
  • checkAndEmitDynamicWorkerCreationEvents
  • +
  • checkAndEmitTaskExecutionEvents
  • +
  • checkAndEmitTaskQueuingEvents
  • checkDynamicPoolSize
  • checkFilePath
  • checkMessageWorkerId
  • @@ -1316,88 +1522,61 @@ Can be overridden.

  • getWorkerNodeKeyByWorkerId
  • handleTaskExecutionResponse
  • handleWorkerReadyResponse
  • +
  • hasBackPressure
  • +
  • hasWorkerNodeBackPressure
  • internalBusy
  • isMain
  • +
  • listTaskFunctions
  • redistributeQueuedTasks
  • registerWorkerMessageListener
  • removeWorkerNode
  • +
  • sendKillMessageToWorker
  • sendStartupMessageToWorker
  • +
  • sendStatisticsMessageToWorker
  • sendToWorker
  • -
  • sendWorkerStatisticsMessageToWorker
  • setTasksQueueOptions
  • +
  • setTasksQueueSize
  • setWorkerChoiceStrategy
  • setWorkerChoiceStrategyOptions
  • setupHook
  • shallCreateDynamicWorker
  • +
  • shallExecuteTask
  • +
  • shallUpdateTaskFunctionWorkerUsage
  • startPool
  • +
  • taskStealingOnEmptyQueue
  • tasksQueueSize
  • +
  • tasksStealingOnBackPressure
  • updateEluWorkerUsage
  • updateRunTimeWorkerUsage
  • updateTaskStatisticsWorkerUsage
  • +
  • updateTaskStolenStatisticsWorkerUsage
  • updateWaitTimeWorkerUsage
  • workerListener
  • +
    -

    Generated using TypeDoc

    -
    \ No newline at end of file +

    Generated using TypeDoc

    +
    \ No newline at end of file