X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicClusterPool.html;h=c4179afc91e67bdefced71f38c269d9ddc420824;hb=3aaed019abde0022e986c1db05db9d5d7bc76594;hp=eb83929c53eaaa756628630e017ee318324fde47;hpb=ed1ecf09c599769ed61771ec25d71c39c19ba70b;p=poolifier.git diff --git a/docs/classes/DynamicClusterPool.html b/docs/classes/DynamicClusterPool.html index eb83929c..c4179afc 100644 --- a/docs/classes/DynamicClusterPool.html +++ b/docs/classes/DynamicClusterPool.html @@ -1,11 +1,13 @@ DynamicClusterPool | poolifier
-
+
  • The search index is not available
    • poolifier +
    @@ -18,10 +20,6 @@

    This cluster pool creates new workers when the others are busy, up to the maximum number of workers. When the maximum number of workers is reached, an event is emitted. If you want to listen to this event, use the pool's emitter.

    -

    Template

    of data sent to the worker. This can only be serializable data.

    - -

    Template

    of response of execution. This can only be serializable data.

    -

    Author

    Christopher Quadflieg

    Since

    2.0.0

    @@ -30,9 +28,13 @@ When the maximum number of workers is reached, an event is emitted. If you want

    Type Parameters

    • -

      Data = unknown

      • +

      Data = unknown

      +

      Type of data sent to the worker. This can only be serializable data.

      +
    • -

      Response = unknown

    +

    Response = unknown

    +

    Type of response of execution. This can only be serializable data.

    +

    Hierarchy

      @@ -40,7 +42,7 @@ When the maximum number of workers is reached, an event is emitted. If you want
      • DynamicClusterPool
    +
  • Defined in src/pools/cluster/dynamic.ts:16
    • @@ -54,7 +56,7 @@ When the maximum number of workers is reached, an event is emitted. If you want

    Properties

    emitter? filePath -max +max nextMessageId numberOfWorkers opts @@ -84,7 +86,6 @@ When the maximum number of workers is reached, an event is emitted. If you want getWorkerAverageTasksRunTime getWorkerIndex getWorkerRunningTasks -initWorkerTasksUsage internalExecute internalGetBusyStatus isMain @@ -100,7 +101,7 @@ When the maximum number of workers is reached, an event is emitted. If you want

    constructor

      - +

    • Constructs a new poolifier dynamic cluster pool.

      @@ -127,37 +128,34 @@ When the maximum number of workers is reached, an event is emitted. If you want

      Path to an implementation of a ClusterWorker file, which can be relative or absolute.

    • -
      Optional opts: ClusterPoolOptions = {}
      +
      opts: ClusterPoolOptions = {}

      Options for this dynamic cluster pool.

    Returns DynamicClusterPool<Data, Response>

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

    • Properties

    Optional Readonly emitter

    -
    emitter?: PoolEmitter
    +
    emitter?: PoolEmitter

    Inherit Doc

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

    • Readonly filePath

    filePath: string
    -
    -

    Readonly max

    -
    max: number
    -
    -

    Inherit Doc

    +
    +

    Protected Readonly max

    +
    max: number
    +
  • Defined in src/pools/cluster/dynamic.ts:30

    • Protected nextMessageId

    nextMessageId: number = 0
    @@ -165,19 +163,19 @@ When the maximum number of workers is reached, an event is emitted. If you want
    +
  • Defined in src/pools/abstract-pool.ts:58

    • Readonly numberOfWorkers

    numberOfWorkers: number
    +
  • Defined in src/pools/abstract-pool.ts:79

    • Readonly opts

    opts: ClusterPoolOptions = {}
    +
  • Defined in src/pools/cluster/fixed.ts:53

    • Protected promiseMap

    promiseMap: Map<number, PromiseWorkerResponseWrapper<Worker, Response>> = ...
    @@ -190,7 +188,7 @@ When the maximum number of workers is reached, an event is emitted. If you want
    +
  • Defined in src/pools/abstract-pool.ts:50

    • Protected workerChoiceStrategyContext

    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -199,7 +197,7 @@ When the maximum number of workers is reached, an event is emitted. If you want
    +
  • Defined in src/pools/abstract-pool.ts:65

    • Readonly workers

    workers: Worker[] = []
    @@ -207,7 +205,7 @@ When the maximum number of workers is reached, an event is emitted. If you want

    Inherit Doc

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

    • Readonly workersTasksUsage

    workersTasksUsage: Map<Worker, TasksUsage> = ...
    @@ -215,7 +213,7 @@ When the maximum number of workers is reached, an event is emitted. If you want

    Inherit Doc

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

    • Accessors

    @@ -228,7 +226,7 @@ When the maximum number of workers is reached, an event is emitted. If you want

    Returns boolean

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

    • numberOfRunningTasks

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

    • type

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

    • Methods

    @@ -275,7 +273,7 @@ Can be overridden.

    Returns void

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

    • Protected afterWorkerSetup

    +
  • Defined in src/pools/cluster/fixed.ts:93

    • Protected beforePromiseWorkerResponseHook

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

    • Protected chooseWorker

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

    • Protected createAndSetupWorker

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

    • Protected createWorker

    +
  • Defined in src/pools/cluster/fixed.ts:88

    • destroy

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

    • destroyWorker

    +
  • Defined in src/pools/cluster/fixed.ts:69

    • execute

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

    • findFreeWorker

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

    • getWorkerAverageTasksRunTime

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

    • getWorkerIndex

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

    • getWorkerRunningTasks

    -
    -

    initWorkerTasksUsage

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

    • Protected internalExecute

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

    • Protected internalGetBusyStatus

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

    • Protected isMain

    +
  • Defined in src/pools/cluster/fixed.ts:64

    • registerWorkerMessageListener

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

    • Protected removeWorker

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

    • Protected sendToWorker

    +
  • Defined in src/pools/cluster/fixed.ts:75

    • setWorkerChoiceStrategy

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

    • Protected setupHook

    +
  • Defined in src/pools/cluster/fixed.ts:59

    • Protected workerListener

    +
  • Defined in src/pools/abstract-pool.ts:365
    • @@ -658,7 +638,7 @@ Can be overridden.

  • constructor
  • emitter?
  • filePath
    • -
  • max
    • +
  • max
  • nextMessageId
  • numberOfWorkers
  • opts
    • @@ -682,7 +662,6 @@ Can be overridden.

  • getWorkerAverageTasksRunTime
  • getWorkerIndex
  • getWorkerRunningTasks
    • -
  • initWorkerTasksUsage
  • internalExecute
  • internalGetBusyStatus
  • isMain