X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=4f501d6f503d1bdab4b5ab50ca3e7d2d989f409e;hb=0cf6d1374ad842cc31aca1a8ddaa1bc5a9b9302b;hp=92d46d153c26a6e332bce691985d560adac71ee5;hpb=341ec6db3b66173fd9314338b736fabb0639914b;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 92d46d15..4f501d6f 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,13 +1,13 @@ -AbstractPool | poolifier - v2.6.40
+AbstractPool | poolifier - v3.0.4
-
+
  • The search index is not available
  • poolifier - v3.0.4 +
    @@ -49,19 +49,19 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:65
  • - +

    Constructors

    -

    Properties

    -

    Accessors

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

    Methods

    -
    addWorkerNode +
    addTaskFunction +addWorkerNode afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook @@ -95,67 +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 -taskStealingOnEmptyQueue +start tasksQueueSize -tasksStealingOnBackPressure +unsetTaskStealing +unsetTasksStealingOnBackPressure updateEluWorkerUsage updateRunTimeWorkerUsage updateTaskStatisticsWorkerUsage updateTaskStolenStatisticsWorkerUsage updateWaitTimeWorkerUsage -workerListener +workerMessageListener

    Constructors

    - +
    • @@ -176,25 +188,29 @@
    • numberOfWorkers: number

      Number of workers that this pool should manage.

      -
    • +
    +
  • filePath: string

    Path to the worker file.

    -
  • +
    +
  • opts: PoolOptions<Worker>

    Options for the pool.

    -
  • + +

    Returns AbstractPool<Worker, Data, Response>

    +
  • 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.
    • @@ -209,7 +225,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:74
  • filePath: string
    @@ -217,7 +233,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:129
  • max?: number
    @@ -225,7 +241,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:79
  • numberOfWorkers: number
    @@ -233,7 +249,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:128
  • opts: PoolOptions<Worker>
    @@ -241,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.
    • @@ -254,7 +270,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:88
  • startTimestamp: number
    @@ -262,7 +278,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:118
  • started: boolean
    @@ -270,15 +286,27 @@
    +
  • Defined in src/pools/abstract-pool.ts:110
  • - +
    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>
    @@ -286,7 +314,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:94
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -295,7 +323,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:71
  • Accessors

    @@ -309,7 +337,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:668
  • +
  • Defined in src/pools/abstract-pool.ts:659
  • +
  • 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

    +
    + +
    + +

    Returns number

    The added worker node key.

    Throws

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

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

    Returns void

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

    Returns void

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1011
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:598
  • +
  • Defined in src/pools/abstract-pool.ts:1588
  • +
  • Defined in src/pools/abstract-pool.ts:1576
  • -
    - -
    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:1582
  • Returns void

    Throws

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

    +
  • 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:1168
  • +
  • Defined in src/pools/abstract-pool.ts:1258
  • +
  • Defined in src/pools/abstract-pool.ts:1214
  • +
  • Defined in src/pools/abstract-pool.ts:1207
  • +
    + +

    Returns undefined | Task<Data>

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

    Returns Promise<void>

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:563
  • Returns number

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

    Returns Promise<Response>

    Promise that will be fulfilled when the task is completed.

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

    Returns void

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

    Returns void

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

    Returns undefined | WorkerInfo

    The worker information.

    + +
    +

    Returns WorkerInfo

    The worker information.

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

    Returns number

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

    +
  • Defined in src/pools/abstract-pool.ts:511
  • Returns number

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

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

    Returns void

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

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

    Returns boolean

    true if the worker node has back pressure, false otherwise.

    +
  • Defined in src/pools/abstract-pool.ts:1648
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:675
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:1002
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:843
  • Returns void

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

    Returns void

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

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

    Returns void

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

    Returns void

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

    Returns void

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

    Returns void

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

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

    Returns void

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:549
  • +
  • Defined in src/pools/abstract-pool.ts:995
  • +
  • Defined in src/pools/abstract-pool.ts:1185
  • Returns boolean

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

    Returns boolean

    true if the worker node shall update its task function worker usage, false otherwise.

    -
    - -
    -
    - -
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:932
  • Returns number

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

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

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

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

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

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

    Generated using TypeDoc

    -
    \ No newline at end of file +
    \ No newline at end of file