X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=905e085b6ed963eb2e2a81ee9ea6fc6774756b6f;hb=5543cb1ca8011b99a67fcd5fd3a7a5c2b1c4a85e;hp=92d46d153c26a6e332bce691985d560adac71ee5;hpb=cc35cd9cb7323e39c9f521cdd4fbf51d1d31bbdf;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 92d46d15..905e085b 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,13 +1,13 @@ -AbstractPool | poolifier - v2.6.40
+AbstractPool | poolifier - v2.7.1
-
+
  • The search index is not available
  • poolifier - v2.7.1 +
    @@ -49,19 +49,19 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:64
  • - +

    Constructors

    -

    Properties

    -

    Accessors

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

    Methods

    -
    addWorkerNode +
    addTaskFunction +addWorkerNode afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook @@ -95,19 +97,17 @@ checkAndEmitDynamicWorkerCreationEvents checkAndEmitTaskExecutionEvents checkAndEmitTaskQueuingEvents -checkDynamicPoolSize -checkFilePath checkMessageWorkerId checkNumberOfWorkers checkPoolOptions -checkValidTasksQueueOptions -checkValidWorkerChoiceStrategy checkValidWorkerChoiceStrategyOptions chooseWorkerNode createAndSetupDynamicWorkerNode createAndSetupWorkerNode createWorker +deleteTaskFunctionWorkerUsages dequeueTask +deregisterWorkerMessageListener destroy destroyWorkerNode enableTasksQueue @@ -122,29 +122,39 @@ handleTaskExecutionResponse handleWorkerReadyResponse hasBackPressure +hasTaskFunction hasWorkerNodeBackPressure 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 taskStealingOnEmptyQueue tasksQueueSize tasksStealingOnBackPressure +unsetTaskStealing +unsetTasksStealingOnBackPressure updateEluWorkerUsage updateRunTimeWorkerUsage updateTaskStatisticsWorkerUsage @@ -155,7 +165,7 @@

    Constructors

    - +
    • @@ -176,19 +186,22 @@
    • 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:126
  • Properties

    @@ -209,7 +222,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:73
  • filePath: string
    @@ -217,7 +230,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:128
  • max?: number
    @@ -225,7 +238,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:97
  • numberOfWorkers: number
    @@ -233,7 +246,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:127
  • opts: PoolOptions<Worker>
    @@ -241,11 +254,11 @@
    +
  • Defined in src/pools/abstract-pool.ts:129
  • 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 +267,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:82
  • startTimestamp: number
    @@ -262,7 +275,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:117
  • started: boolean
    @@ -270,15 +283,27 @@
    +
  • Defined in src/pools/abstract-pool.ts:109
  • - +
    starting: boolean

    Whether the pool is starting or not.

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

    The task functions added at runtime map:

    + +
    +
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -286,7 +311,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:88
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -295,7 +320,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:70
  • Accessors

    @@ -309,7 +334,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:654
  • +
  • Defined in src/pools/abstract-pool.ts:645
  • +
  • Defined in src/pools/abstract-pool.ts:265
  • +
  • Defined in src/pools/abstract-pool.ts:478
  • +
  • Defined in src/pools/abstract-pool.ts:471
  • +
  • Defined in src/pools/abstract-pool.ts:423
  • +
  • Defined in src/pools/abstract-pool.ts:461
  • +
  • Defined in src/pools/abstract-pool.ts:440
  • +
  • Defined in src/pools/abstract-pool.ts:466
  • 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:1587
  • + +

    Returns void

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

    Returns void

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

    Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:594
  • +
  • Defined in src/pools/abstract-pool.ts:1562
  • +
  • Defined in src/pools/abstract-pool.ts:1550
  • -
    - -
    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:1556
  • Returns void

    Throws

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:217
  • +
  • Defined in src/pools/abstract-pool.ts:1153
  • +
  • Defined in src/pools/abstract-pool.ts:1243
  • +
  • Defined in src/pools/abstract-pool.ts:1199
  • +
  • Defined in src/pools/abstract-pool.ts:1192
  • +
    + +

    Returns undefined | Task<Data>

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

    Returns Promise<void>

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

    Returns void

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

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

    Returns Promise<Response>

    Promise that will be fulfilled when the task is completed.

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

    Returns void

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

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

    Returns undefined | WorkerInfo

    The worker information.

    + +
    +

    Returns WorkerInfo

    The worker information.

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

    Returns number

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

    +
  • Defined in src/pools/abstract-pool.ts:507
  • 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:519
  • Returns void

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

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

    Returns boolean

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

    +
  • Defined in src/pools/abstract-pool.ts:1618
  • +
  • Defined in src/pools/abstract-pool.ts:661
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:987
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:829
  • Returns void

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

    Returns void

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

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

    Returns void

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

    Returns void

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

    Returns void

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

    Returns void

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

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

    Returns void

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:545
  • +
  • Defined in src/pools/abstract-pool.ts:980
  • +
  • Defined in src/pools/abstract-pool.ts:1170
  • Returns boolean

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

    Returns boolean

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

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

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

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

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

    Returns void

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:1100
  • +
  • Defined in src/pools/abstract-pool.ts:1488
  • @@ -1442,6 +1694,7 @@ Can be overridden.

  • startTimestamp
  • started
  • starting
  • +
  • taskFunctions
  • workerChoiceStrategyContext
  • workerNodes
  • busy
  • @@ -1453,6 +1706,7 @@ Can be overridden.

  • type
  • utilization
  • worker
  • +
  • addTaskFunction
  • addWorkerNode
  • afterTaskExecutionHook
  • afterWorkerNodeSetup
  • @@ -1461,19 +1715,17 @@ Can be overridden.

  • checkAndEmitDynamicWorkerCreationEvents
  • checkAndEmitTaskExecutionEvents
  • checkAndEmitTaskQueuingEvents
  • -
  • checkDynamicPoolSize
  • -
  • checkFilePath
  • checkMessageWorkerId
  • checkNumberOfWorkers
  • checkPoolOptions
  • -
  • checkValidTasksQueueOptions
  • -
  • checkValidWorkerChoiceStrategy
  • checkValidWorkerChoiceStrategyOptions
  • chooseWorkerNode
  • createAndSetupDynamicWorkerNode
  • createAndSetupWorkerNode
  • createWorker
  • +
  • deleteTaskFunctionWorkerUsages
  • dequeueTask
  • +
  • deregisterWorkerMessageListener
  • destroy
  • destroyWorkerNode
  • enableTasksQueue
  • @@ -1488,29 +1740,39 @@ Can be overridden.

  • handleTaskExecutionResponse
  • handleWorkerReadyResponse
  • hasBackPressure
  • +
  • hasTaskFunction
  • hasWorkerNodeBackPressure
  • 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
  • taskStealingOnEmptyQueue
  • tasksQueueSize
  • tasksStealingOnBackPressure
  • +
  • unsetTaskStealing
  • +
  • unsetTasksStealingOnBackPressure
  • updateEluWorkerUsage
  • updateRunTimeWorkerUsage
  • updateTaskStatisticsWorkerUsage
  • @@ -1518,71 +1780,30 @@ Can be overridden.

  • updateWaitTimeWorkerUsage
  • workerListener
  • +

    Generated using TypeDoc

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