X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicThreadPool.html;h=9e347897eeb2da3b82e3e5c256920cba0ba62751;hb=fb8fbcfd7983c1eadc39411c9b29054e6fa97d5b;hp=26289e94772a1f37b1abd17a9e09150e8bc9c459;hpb=68887e30ceca3df78b70e0b8f1b262a76f2d7cd8;p=poolifier.git diff --git a/docs/classes/DynamicThreadPool.html b/docs/classes/DynamicThreadPool.html index 26289e94..9e347897 100644 --- a/docs/classes/DynamicThreadPool.html +++ b/docs/classes/DynamicThreadPool.html @@ -1,4 +1,4 @@ -DynamicThreadPool | poolifier - v2.6.12
+DynamicThreadPool | poolifier - v2.6.28
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.12
+
  • The search index is not available
  • poolifier - v2.6.28
    @@ -45,7 +45,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    • DynamicThreadPool
    +
  • Defined in src/pools/thread/dynamic.ts:15
  • @@ -74,7 +74,6 @@ When the maximum number of threads is reached and workers are busy, an event is maxSize minSize ready -starting type utilization worker @@ -82,18 +81,24 @@ When the maximum number of threads is reached and workers are busy, an event is

    Methods

    +
  • Defined in src/pools/thread/dynamic.ts:27
  • Properties

    @@ -153,9 +158,10 @@ When the maximum number of threads is reached and workers are busy, an event is

    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.
    @@ -163,7 +169,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:65
  • filePath: string
    @@ -172,7 +178,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:109
  • max: number
    @@ -180,7 +186,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/thread/dynamic.ts:29
  • numberOfWorkers: number
    @@ -189,7 +195,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:108
  • @@ -198,11 +204,11 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/thread/fixed.ts:49
  • -
    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.
    • @@ -212,7 +218,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:75
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -221,7 +227,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:81
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -230,7 +236,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:62
  • Accessors

    @@ -245,7 +251,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/thread/dynamic.ts:48
    • @@ -258,7 +264,7 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:615
    • @@ -270,93 +276,87 @@ When the maximum number of threads is reached and workers are busy, an event is
    +
  • Defined in src/pools/abstract-pool.ts:308
    • get maxSize(): number
    • -

      Pool maximum size.

      +

      The pool maximum size.

      Returns number

    +
  • Defined in src/pools/thread/dynamic.ts:43
    • get minSize(): number
    • -

      Pool minimum size.

      +

      The pool minimum size.

      Returns number

    +
  • Defined in src/pools/thread/fixed.ts:132
    • get ready(): boolean
    • -

      Returns boolean

    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:451
    • get type(): "fixed" | "dynamic"
    • -

      Pool type.

      +

      The pool type.

      If it is 'dynamic', it provides the max property.

      Returns "fixed" | "dynamic"

    +
  • Defined in src/pools/thread/dynamic.ts:38
    • get utilization(): number
    • -

      Gets the approximate pool utilization.

      +

      The approximate pool utilization.

      Returns number

      The pool utilization.

    +
  • Defined in src/pools/abstract-pool.ts:468
    • -
    • get worker(): "cluster" | "thread"
    • +
    • get worker(): "thread" | "cluster"
    • -

      Gets the worker type.

      +

      The worker type.

      -

      Returns "cluster" | "thread"

      +

      Returns "thread" | "cluster"

    +
  • Defined in src/pools/thread/fixed.ts:127
  • Methods

      - +
    • Hook executed after the worker task execution. Can be overridden.

      @@ -365,8 +365,8 @@ Can be overridden.

      Parameters

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

      Function that can be hooked up when a worker has been newly created and moved to the pool worker nodes. +

      Method hooked up after a worker node has been newly created. Can be overridden.

      Parameters

      • -
        worker: Worker
        -

        The newly created worker.

        +
        workerNodeKey: number
        +

        The newly created worker node key.

      Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1028
  • +
  • Defined in src/pools/abstract-pool.ts:774
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:180
  • +
    +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:975
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:935
  • +
  • Defined in src/pools/thread/fixed.ts:114
  • -
    - +
  • Defined in src/pools/abstract-pool.ts:720
  • +
    +
    +
  • Defined in src/pools/thread/fixed.ts:60
  • +
  • Defined in src/pools/abstract-pool.ts:580
    • - +
    • Executes the specified function in the worker constructor with the task data input parameter.

      @@ -550,12 +550,17 @@ Can be overridden.

      • Optional data: Data
        -

        The task input data for the specified worker function. This can only be structured-cloneable data.

        +

        The optional task input data for the specified task function. This can only be structured-cloneable data.

      • Optional name: string
        -

        The name of the worker function to execute. If not specified, the default worker function will be executed.

        +

        The optional name of the task function to execute. If not specified, the default task function will be executed.

        +
        +
      • +
      • +
        Optional transferList: TransferListItem[]
        +

        An optional array of transferable objects to transfer ownership of. Ownership of the transferred objects is given to the pool's worker_threads worker and they should not be used in the main thread afterwards.

    Returns Promise<Response>

    Promise that will be fulfilled when the task is completed.

    @@ -563,20 +568,55 @@ Can be overridden.

    +
  • Defined in src/pools/abstract-pool.ts:661
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:631
  • +
  • Defined in src/pools/thread/fixed.ts:55
  • +
    + +
    +
    + +
    +
    + +
    +
    + +
    +
  • Defined in src/pools/thread/fixed.ts:77
  • +
  • Defined in src/pools/abstract-pool.ts:592
  • +
  • Defined in src/pools/abstract-pool.ts:550
  • +
  • Defined in src/pools/abstract-pool.ts:569
  • +
  • Defined in src/pools/abstract-pool.ts:758
  • +
  • Defined in src/pools/abstract-pool.ts:1111