X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=7f201407c20601a160864b3a7f517daafefb0211;hb=d8e6bb3c5f8adc1797760260a1a22c228f76e984;hp=61a6611428c1770267bf40df482f7b0e814956b9;hpb=3db479d12e6d8dff22ca35537d96af8d6830ff13;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 61a66114..7f201407 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.6.14
+AbstractPool | poolifier - v2.6.27
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.14
+
  • The search index is not available
  • poolifier - v2.6.27
    @@ -78,7 +80,6 @@ maxSize minSize ready -starting type utilization worker @@ -87,7 +88,7 @@

    Methods

    addWorkerNode afterTaskExecutionHook -afterWorkerSetup +afterWorkerNodeSetup beforeTaskExecutionHook buildTasksQueueOptions checkAndEmitEvents @@ -100,36 +101,39 @@ checkValidWorkerChoiceStrategy checkValidWorkerChoiceStrategyOptions chooseWorkerNode -createAndSetupDynamicWorker -createAndSetupWorker +createAndSetupDynamicWorkerNode +createAndSetupWorkerNode createWorker dequeueTask destroy -destroyWorker +destroyWorkerNode enableTasksQueue enqueueTask execute executeTask -flushTasksQueue +flushTasksQueue flushTasksQueues -getWorkerById -getWorkerInfo -getWorkerNodeKey +getWorkerInfo +getWorkerNodeKeyByWorker +getWorkerNodeKeyByWorkerId handleTaskExecutionResponse -handleWorkerReadyMessage +handleWorkerReadyResponse internalBusy isMain +listTaskFunctions redistributeQueuedTasks -registerWorkerMessageListener +registerWorkerMessageListener removeWorkerNode +sendKillMessageToWorker +sendStartupMessageToWorker +sendStatisticsMessageToWorker sendToWorker -sendWorkerStartupMessage setTasksQueueOptions setWorkerChoiceStrategy setWorkerChoiceStrategyOptions -setWorkerStatistics setupHook shallCreateDynamicWorker +startPool tasksQueueSize updateEluWorkerUsage updateRunTimeWorkerUsage @@ -176,7 +180,7 @@

    Returns AbstractPool<Worker, Data, Response>

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

    @@ -185,9 +189,10 @@

    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.
    • +
    • '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.
    @@ -195,7 +200,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:65
  • filePath: string
    @@ -203,7 +208,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:109
  • numberOfWorkers: number
    @@ -211,7 +216,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:108
  • opts: PoolOptions<Worker>
    @@ -219,11 +224,11 @@
    +
  • Defined in src/pools/abstract-pool.ts:110
  • -
    promiseResponseMap: Map<string, PromiseResponseWrapper<Worker, Response>> = ...
    -

    The execution response promise map.

    +
    promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    +

    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.
    • @@ -232,7 +237,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:75
  • startTimestamp: number
    @@ -240,7 +245,23 @@
    +
  • Defined in src/pools/abstract-pool.ts:94
  • +
    + +
    starting: boolean
    +

    Whether the pool is starting or not.

    +
    +
    +
    + +
    taskFunctions: string[]
    +

    The task function names.

    +
    +
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -248,7 +269,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:81
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -257,7 +278,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:62
  • Accessors

    @@ -271,7 +292,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:622
  • +
  • Defined in src/pools/abstract-pool.ts:613
  • +
  • Defined in src/pools/abstract-pool.ts:308
  • +
  • Defined in src/pools/abstract-pool.ts:504
  • +
  • Defined in src/pools/abstract-pool.ts:499
  • -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:451
  • +
  • Defined in src/pools/abstract-pool.ts:489
  • +
  • Defined in src/pools/abstract-pool.ts:468
  • +
  • Defined in src/pools/abstract-pool.ts:494
  • Methods

    @@ -386,15 +402,17 @@

    The worker.

    -

    Returns number

    The worker nodes length.

    +

    Returns number

    The added worker node key.

    -
    +
  • Defined in src/pools/abstract-pool.ts:1191
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:793
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:1026
  • +
  • Defined in src/pools/abstract-pool.ts:772
  • Returns TasksQueueOptions

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

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

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

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:243
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:887
  • +
    +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:973
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:933
  • +
  • Defined in src/pools/abstract-pool.ts:926
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1233
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:718
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:748
  • +
  • Defined in src/pools/abstract-pool.ts:578
  • Returns number

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1241
  • -
    - -
    +
    + +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:1180
  • +
    +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:529
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:541
  • Returns void

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1125
  • +
  • Defined in src/pools/abstract-pool.ts:629
  • +
  • Defined in src/pools/abstract-pool.ts:763
  • +
    + +

    Returns void

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

    Returns void

    +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:915
  • +
  • Defined in src/pools/abstract-pool.ts:590
  • +
  • Defined in src/pools/abstract-pool.ts:548
  • -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:567
  • +
  • Defined in src/pools/abstract-pool.ts:756
  • +
  • Defined in src/pools/abstract-pool.ts:904
  • +
    + +

    Returns number

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

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

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

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

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