X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicThreadPool.html;h=de2edc9d8649f9a8a2c83a1386b686ddedd67699;hb=8d98e603c79d8d00b2b6a33e5f732701a7466234;hp=f6495e279a204f5ba19c7dc378617f980e5bffea;hpb=ec06e4dd01adf7aa4bab470c59da42c19d863d0b;p=poolifier.git diff --git a/docs/classes/DynamicThreadPool.html b/docs/classes/DynamicThreadPool.html index f6495e27..de2edc9d 100644 --- a/docs/classes/DynamicThreadPool.html +++ b/docs/classes/DynamicThreadPool.html @@ -1,4 +1,4 @@ -DynamicThreadPool | poolifier
+DynamicThreadPool | poolifier
-
+

Type Parameters

-
    +
    • -

      Data = unknown

      +

      Data = unknown

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

    • -

      Response = unknown

      -

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

      +

      Response = unknown

      +

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

Hierarchy

+
  • Defined in src/pools/thread/dynamic.ts:15
  • @@ -50,130 +50,141 @@ When the maximum number of threads is reached and workers are busy, an event is

    Constructors

    -
    +
    -
      - +
        +
      • Constructs a new poolifier dynamic thread pool.

        -
        +

        Type Parameters

        -
          +
          • -

            Data = unknown

          • +

            Data = unknown

          • -

            Response = unknown

        +

        Response = unknown

    Parameters

    • -
      min: number
      +
      min: number

      Minimum number of threads which are always active.

    • -
      max: number
      +
      max: number

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

    • -
      filePath: string
      +
      filePath: string

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

    • -
      opts: PoolOptions<ThreadWorkerWithMessageChannel> = {}
      +
      opts: PoolOptions<ThreadWorkerWithMessageChannel> = {}

      Options for this dynamic thread pool.

    -

    Returns DynamicThreadPool<Data, Response>

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

    -
    +
    -
    emitter?: PoolEmitter
    -
    -

    Inherit Doc

    -
    - -
    filePath: string
    -

    Path to the worker-file.

    +
  • Defined in src/pools/abstract-pool.ts:47
  • +
    + +
    filePath: string
    +

    Path to the worker file.

    -
    - -
    max: number
    +
  • Defined in src/pools/abstract-pool.ts:82
  • +
    + +
    max: number

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

    -
    - -
    numberOfWorkers: number
    +
  • Defined in src/pools/thread/dynamic.ts:29
  • +
    + +
    numberOfWorkers: number

    Number of workers that this pool should manage.

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

    Options for the pool.

    -
    +
  • Defined in src/pools/abstract-pool.ts:83
  • +
    -
    promiseResponseMap: Map<string, PromiseResponseWrapper<ThreadWorkerWithMessageChannel, Response>> = ...
    +
    promiseResponseMap: Map<string, PromiseResponseWrapper<ThreadWorkerWithMessageChannel, Response>> = ...

    The execution response promise map.

    • key: The message id of each submitted task.
    • @@ -183,87 +194,112 @@ When the maximum number of threads is reached and workers are busy, an event is
    -
    +
  • Defined in src/pools/abstract-pool.ts:57
  • +
    -
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<ThreadWorkerWithMessageChannel, Data, Response>
    +
    workerChoiceStrategyContext: WorkerChoiceStrategyContext<ThreadWorkerWithMessageChannel, Data, Response>

    Worker choice strategy context referencing a worker choice algorithm implementation.

    Default to a round robin algorithm.

    -
    +
  • Defined in src/pools/abstract-pool.ts:67
  • +
    -
    workerNodes: WorkerNode<ThreadWorkerWithMessageChannel, Data>[] = []
    -
    -

    Inherit Doc

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

    -
    - -
    +
    + +
    • get full(): boolean
    • -
      -

      Inherit Doc

      +

      Whether the pool is full or not.

      +

      The pool filling boolean status.

      +

      Returns boolean

    -
    - -
    +
    + +
    +
    + +
      +
    • get maxSize(): number
    • +
    • +

      Pool maximum size.

      Returns number

    -
    - -
    +
    + +
      +
    • get minSize(): number
    • -

      Number of tasks running in the pool.

      +

      Pool minimum size.

      Returns number

    -
    - -
    +
    + +
      +
    • get type(): "fixed" | "dynamic"
    • -
      -

      Inherit Doc

      -

      Returns PoolType

    +
  • Defined in src/pools/thread/dynamic.ts:37
  • +
    + +
      +
    • get worker(): "cluster" | "thread"
    • +
    • +

      Gets the worker type.

      +
      +

      Returns "cluster" | "thread"

    Methods

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

        Inherit Doc

        +

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

        +

        Can be used to update the maxListeners or binding the main-worker<->worker connection if not bind by default.

        +

        Parameters

        +
        worker: ThreadWorkerWithMessageChannel
        +

        The newly created worker.

        +

    Returns void

    -
    +
  • Defined in src/pools/thread/fixed.ts:90
  • +
    -
      - +
        +
      • Hook executed before the worker task execution. Can be overridden.

        @@ -311,197 +350,265 @@ Can be overridden.

        Parameters

        • -
          workerNodeKey: number
          +
          workerNodeKey: number

          The worker node key.

        Returns void

    -
    +
  • Defined in src/pools/abstract-pool.ts:453
  • +
    -
    -
    +
  • Defined in src/pools/abstract-pool.ts:532
  • +
    -
    -
    +
  • Defined in src/pools/abstract-pool.ts:596
  • +
    -
    -
    +
  • Defined in src/pools/thread/fixed.ts:83
  • +
    -
    -
    - -
    +
    + + +

    Returns Promise<void>

    -
    - -
    +
    + +
      +
    • -
      -

      Inherit Doc

      +

      Enables/disables the worker tasks queue in this pool.

      +

      Parameters

      • -
        data: Data
      -

      Returns Promise<Response>

    • +
    • +
      Optional tasksQueueOptions: TasksQueueOptions
      +

      The worker tasks queue options.

      +
    +

    Returns void

    -
    - -
    +
    + +
      +
    • -
      -

      Inherit Doc

      -

      Returns number

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

      Inherit Doc

      -
      +

      Registers a listener callback on the given worker.

      +
      +

      Type Parameters

      -
        +
        • -

          Message

      +

      Message

    Parameters

    • -
      messageChannel: ThreadWorkerWithMessageChannel
    • +
      worker: ThreadWorkerWithMessageChannel
      +

      The worker which should register a listener.

      +
    • -
      listener: ((message: MessageValue<Message, unknown>) => void)
      +
      listener: ((message) => void)
      +

      The message listener callback.

      +
      • -
          -
        • (message: MessageValue<Message, unknown>): void
        • +
            +
          • (message): void
          • Parameters

            • -
              message: MessageValue<Message, unknown>
            +
            message: MessageValue<Message, Worker | MessagePort>

    Returns void

    Returns void

    -
    +
  • Defined in src/pools/thread/fixed.ts:75
  • +
    -
    -
    +
  • Defined in src/pools/thread/fixed.ts:67
  • +
    + +
    +
    -
      - +
        +
      • -
        -

        Inherit Doc

        +

        Sets the worker choice strategy in this pool.

        +

        Parameters

        • -
          workerChoiceStrategy: "ROUND_ROBIN" | "LESS_USED" | "LESS_BUSY" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN"
        +
        workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN"
        +

        The worker choice strategy.

        +
      • +
      • +
        Optional workerChoiceStrategyOptions: WorkerChoiceStrategyOptions
        +

        The worker choice strategy options.

        +

      Returns void

    -
    +
  • Defined in src/pools/abstract-pool.ts:284
  • +
    + +
    +
    -
      - +
    -
    +
  • Defined in src/pools/abstract-pool.ts:438
  • +
    -
      - +
        +
      • This function is the listener registered for each worker message.

        - -

        Returns

        The listener function to execute when a message is received from a worker.

        -

        Returns ((message: MessageValue<Response, unknown>) => void)

        +

        Returns ((message) => void)

        The listener function to execute when a message is received from a worker.

        +
        • -
            -
          • (message: MessageValue<Response, unknown>): void
          • +
              +
            • (message): void
            • This function is the listener registered for each worker message.

              - -

              Returns

              The listener function to execute when a message is received from a worker.

              Parameters

              • -
                message: MessageValue<Response, unknown>
              -

              Returns void

        +

        Returns void

        The listener function to execute when a message is received from a worker.

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

    Theme

    On This Page

    +
  • constructor
  • +
  • emitter
  • +
  • filePath
  • +
  • max
  • +
  • numberOfWorkers
  • +
  • opts
  • +
  • promiseResponseMap
  • +
  • workerChoiceStrategyContext
  • +
  • workerNodes
  • +
  • busy
  • +
  • full
  • +
  • info
  • +
  • maxSize
  • +
  • minSize
  • +
  • type
  • +
  • worker
  • +
  • afterTaskExecutionHook
  • +
  • afterWorkerSetup
  • +
  • beforeTaskExecutionHook
  • +
  • chooseWorkerNode
  • +
  • createAndSetupWorker
  • +
  • createWorker
  • +
  • destroy
  • +
  • destroyWorker
  • +
  • enableTasksQueue
  • +
  • execute
  • +
  • internalBusy
  • +
  • isMain
  • +
  • registerWorkerMessageListener
  • +
  • sendToWorker
  • +
  • setTasksQueueOptions
  • +
  • setWorkerChoiceStrategy
  • +
  • setWorkerChoiceStrategyOptions
  • +
  • setupHook
  • +
  • workerListener
  • +
  • AbstractPool
  • +
  • AbstractWorker
  • +
  • CircularArray
  • +
  • ClusterWorker
  • +
  • DynamicClusterPool
  • +
  • DynamicThreadPool
  • +
  • FixedClusterPool
  • +
  • FixedThreadPool
  • +
  • PoolEmitter
  • +
  • Queue
  • +
  • ThreadWorker
  • +
  • WorkerChoiceStrategyContext
  • +
  • ClusterPoolOptions
  • +
  • IPool
  • +
  • IWorker
  • +
  • IWorkerChoiceStrategy
  • +
  • MessageValue
  • +
  • PoolInfo
  • +
  • PoolOptions
  • +
  • PromiseResponseWrapper
  • +
  • RequiredStatistics
  • +
  • Task
  • +
  • TasksQueueOptions
  • +
  • TasksUsage
  • +
  • WorkerChoiceStrategyOptions
  • +
  • WorkerNode
  • +
  • WorkerOptions
  • +
  • Draft
  • +
  • ErrorHandler
  • +
  • ExitHandler
  • +
  • KillBehavior
  • +
  • MessageHandler
  • +
  • OnlineHandler
  • +
  • PoolEvent
  • +
  • PoolType
  • +
  • TaskFunctions
  • +
  • ThreadWorkerWithMessageChannel
  • +
  • WorkerAsyncFunction
  • +
  • WorkerChoiceStrategy
  • +
  • WorkerFunction
  • +
  • WorkerSyncFunction
  • +
  • WorkerType
  • +
  • KillBehaviors
  • +
  • PoolEvents
  • +
  • PoolTypes
  • +
  • WorkerChoiceStrategies
  • +
  • WorkerTypes
  • Generated using TypeDoc

    \ No newline at end of file