X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicThreadPool.html;h=267078cc65897c6734582acee4e6f1e00f0eddfb;hb=3aaed019abde0022e986c1db05db9d5d7bc76594;hp=5ed3339c53b338e1e4b4e5cb7cb94e4d1c18e52b;hpb=ed1ecf09c599769ed61771ec25d71c39c19ba70b;p=poolifier.git diff --git a/docs/classes/DynamicThreadPool.html b/docs/classes/DynamicThreadPool.html index 5ed3339c..267078cc 100644 --- a/docs/classes/DynamicThreadPool.html +++ b/docs/classes/DynamicThreadPool.html @@ -1,11 +1,13 @@ DynamicThreadPool | poolifier
-
+
  • The search index is not available
    • poolifier +
    @@ -18,10 +20,6 @@

    This thread pool creates new threads when the others are busy, up to the maximum number of threads. When the maximum number of threads 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

    Alessandro Pio Ardizio

    Since

    0.0.1

    @@ -30,9 +28,13 @@ When the maximum number of threads 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 threads is reached, an event is emitted. If you want
      • DynamicThreadPool
    +
  • Defined in src/pools/thread/dynamic.ts:17
    • @@ -54,7 +56,7 @@ When the maximum number of threads 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 threads 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 threads is reached, an event is emitted. If you want

    constructor

    Returns DynamicThreadPool<Data, Response>

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

    • 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/thread/dynamic.ts:31

    • Protected nextMessageId

    nextMessageId: number = 0
    @@ -165,19 +163,19 @@ When the maximum number of threads 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: PoolOptions<ThreadWorkerWithMessageChannel>
    +
  • Defined in src/pools/abstract-pool.ts:81

    • Protected promiseMap

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

    • Protected workerChoiceStrategyContext

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

    • Readonly workers

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

    Inherit Doc

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

    • Readonly workersTasksUsage

    workersTasksUsage: Map<ThreadWorkerWithMessageChannel, TasksUsage> = ...
    @@ -215,7 +213,7 @@ When the maximum number of threads 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 threads is reached, an event is emitted. If you want

    Returns boolean

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

    • numberOfRunningTasks

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

    • type

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

    • Methods

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

    Returns void

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

    • Protected afterWorkerSetup

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

    • 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/thread/fixed.ts:73

    • destroy

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

    • destroyWorker

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

    • 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/thread/fixed.ts:44

    • registerWorkerMessageListener

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

    • Protected removeWorker

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

    • Protected sendToWorker

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

    • setWorkerChoiceStrategy

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

    • Protected setupHook

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

    • Protected workerListener

    +
  • Defined in src/pools/abstract-pool.ts:365
    • @@ -659,7 +639,7 @@ to run code before workers are created in the abstract constructor.

  • constructor
  • emitter?
  • filePath
    • -
  • max
    • +
  • max
  • nextMessageId
  • numberOfWorkers
  • opts
    • @@ -683,7 +663,6 @@ to run code before workers are created in the abstract constructor.

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