X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicClusterPool.html;h=3667203261acef2973265b71a0b76d1e465e4173;hb=ec06e4dd01adf7aa4bab470c59da42c19d863d0b;hp=f02a5d7a8900078e7992c248deffc6f2e6d4a463;hpb=ba92b02f642f229cb927ab526148f10107831471;p=poolifier.git diff --git a/docs/classes/DynamicClusterPool.html b/docs/classes/DynamicClusterPool.html index f02a5d7a..36672032 100644 --- a/docs/classes/DynamicClusterPool.html +++ b/docs/classes/DynamicClusterPool.html @@ -1,4 +1,4 @@ -DynamicClusterPool | poolifier
+DynamicClusterPool | poolifier
-
+
@@ -56,36 +56,36 @@ When the maximum number of workers is reached and workers are busy, an event is

Properties

Accessors

Methods

-
afterPromiseResponseHook +
afterTaskExecutionHook afterWorkerSetup -beforePromiseResponseHook -chooseWorker +beforeTaskExecutionHook +chooseWorkerNode createAndSetupWorker createWorker destroy destroyWorker execute -findFreeWorkerKey +findFreeWorkerNodeKey internalBusy isMain registerWorkerMessageListener -removeWorker sendToWorker setWorkerChoiceStrategy setupHook @@ -96,7 +96,7 @@ When the maximum number of workers is reached and workers are busy, an event is
    - +
  • Constructs a new poolifier dynamic cluster pool.

    @@ -126,20 +126,20 @@ When the maximum number of workers is reached and workers are busy, an event is
    opts: ClusterPoolOptions = {}

    Options for this dynamic cluster pool.

-

Returns DynamicClusterPool<Data, Response>

+
  • Defined in src/pools/cluster/dynamic.ts:28
  • Properties

    emitter?: PoolEmitter
    -

    {@inheritDoc}

    -
    +
  • Defined in src/pools/abstract-pool.ts:37
  • filePath: string
    @@ -147,14 +147,14 @@ When the maximum number of workers is reached and workers are busy, an event is
    -
    - +
  • Defined in src/pools/abstract-pool.ts:72
  • +
    +
    max: number

    Maximum number of workers that can be created by this pool.

    +
  • Defined in src/pools/cluster/dynamic.ts:30
  • numberOfWorkers: number
    @@ -162,7 +162,7 @@ When the maximum number of workers is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:71
  • @@ -170,37 +170,37 @@ When the maximum number of workers is reached and workers are busy, an event is
    +
  • Defined in src/pools/cluster/fixed.ts:53
  • -
    promiseResponseMap: Map<string, PromiseResponseWrapper<Worker, Response>> = ...
    -

    The promise response map.

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

    The execution response promise map.

    • key: The message id of each submitted task.
    • -
    • value: An object that contains the worker, the promise resolve and reject callbacks.
    • +
    • value: An object that contains the worker, the execution response promise resolve and reject callbacks.
    -

    When we receive a message from the worker we get a map entry with the promise resolve/reject bound to the message.

    +

    When we receive a message from the worker, we get a map entry with the promise resolve/reject bound to the message id.

    +
  • Defined in src/pools/abstract-pool.ts:47
  • -
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    -

    Worker choice strategy instance implementing the worker choice algorithm.

    -

    Default to a strategy implementing a round robin algorithm.

    +
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    +

    Worker choice strategy context referencing a worker choice algorithm implementation.

    +

    Default to a round robin algorithm.

    -
    - -
    workers: WorkerType<Worker>[] = []
    -

    {@inheritDoc}

    -
    +
    + +
    workerNodes: WorkerNode<Worker, Data>[] = []
    +
    +

    Inherit Doc

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

    @@ -208,53 +208,64 @@ When the maximum number of workers is reached and workers are busy, an event is
    +
  • Defined in src/pools/cluster/dynamic.ts:48
  • +
  • Defined in src/pools/cluster/dynamic.ts:43
  • +
    + +
      +
    • get numberOfQueuedTasks(): number
    • +
    • +

      Number of tasks queued in the pool.

      +
      +

      Returns number

    • get numberOfRunningTasks(): number
    • -

      Number of tasks concurrently running.

      +

      Number of tasks running in the pool.

      Returns number

    +
  • Defined in src/pools/abstract-pool.ts:172
  • +
  • Defined in src/pools/cluster/dynamic.ts:38
  • Methods

    -
    - +
    +
      - +
    • -

      Hook executed after the worker task promise resolution. +

      Hook executed after the worker task execution. Can be overridden.

      @@ -265,20 +276,20 @@ Can be overridden.

      The worker.

    • -
      message: MessageValue<Response, unknown>
      +
      message: MessageValue<Response, unknown>

      The received message.

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:323
  • -
    - +
  • Defined in src/pools/cluster/fixed.ts:93
  • +
    +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:312
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:356
  • +
  • Defined in src/pools/abstract-pool.ts:418
  • +
  • Defined in src/pools/cluster/fixed.ts:88
  • +
  • Defined in src/pools/abstract-pool.ts:275
  • +
  • Defined in src/pools/cluster/fixed.ts:69
  • +

    Returns Promise<Response>

    -
    - +
  • Defined in src/pools/abstract-pool.ts:244
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:237
  • +
  • Defined in src/pools/abstract-pool.ts:232
  • +
  • Defined in src/pools/cluster/fixed.ts:64
  • Returns void

    -
    - -
    +
  • Defined in src/pools/cluster/fixed.ts:80
  • Returns void

    +
  • Defined in src/pools/cluster/fixed.ts:75
  • +
  • Defined in src/pools/abstract-pool.ts:205
  • +
  • Defined in src/pools/cluster/fixed.ts:59
  • - +
    +
    -
    +
  • constructor
  • +
  • emitter
  • +
  • filePath
  • +
  • max
  • +
  • numberOfWorkers
  • +
  • opts
  • +
  • promiseResponseMap
  • +
  • workerChoiceStrategyContext
  • +
  • workerNodes
  • +
  • busy
  • +
  • full
  • +
  • numberOfQueuedTasks
  • +
  • numberOfRunningTasks
  • +
  • type
  • +
  • afterTaskExecutionHook
  • +
  • afterWorkerSetup
  • +
  • beforeTaskExecutionHook
  • +
  • chooseWorkerNode
  • +
  • createAndSetupWorker
  • +
  • createWorker
  • +
  • destroy
  • +
  • destroyWorker
  • +
  • execute
  • +
  • findFreeWorkerNodeKey
  • +
  • internalBusy
  • +
  • isMain
  • +
  • registerWorkerMessageListener
  • +
  • sendToWorker
  • +
  • setWorkerChoiceStrategy
  • +
  • setupHook
  • +
  • workerListener
  • + +

    Generated using TypeDoc

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