X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=7f201407c20601a160864b3a7f517daafefb0211;hb=d8e6bb3c5f8adc1797760260a1a22c228f76e984;hp=984c1c21c2da8ba185da4297fe494a7610100b85;hpb=76b46937556ea55049d5c413aa0a77d0c7f47f48;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 984c1c21..7f201407 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.6.19
+AbstractPool | poolifier - v2.6.27
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.19
+
  • The search index is not available
  • poolifier - v2.6.27
    @@ -87,7 +88,7 @@

    Methods

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

    Returns AbstractPool<Worker, Data, Response>

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

    @@ -187,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.
    @@ -197,7 +200,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:65
  • filePath: string
    @@ -205,7 +208,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:109
  • numberOfWorkers: number
    @@ -213,7 +216,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:108
  • opts: PoolOptions<Worker>
    @@ -221,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.
    • @@ -234,7 +237,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:75
  • startTimestamp: number
    @@ -242,7 +245,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:94
  • starting: boolean
    @@ -250,7 +253,15 @@
    +
  • Defined in src/pools/abstract-pool.ts:90
  • +
    + +
    taskFunctions: string[]
    +

    The task function names.

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

    @@ -281,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

    @@ -388,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
  • -
    - -
    -
    - -
    +
    + +
    -
    - -
    +
    + + -

    Returns WorkerInfo

    The worker information.

    +

    Returns number

    The worker node key if found in the pool worker nodes, -1 otherwise.

    -
    -

    Throws

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

    -
    -
    - -
    +
    + +
    +
  • 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:1060
  • +
  • Defined in src/pools/abstract-pool.ts:1210
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1040
  • +
    + +
    +
  • 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
  • +
  • Defined in src/pools/abstract-pool.ts:295
  • 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