X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=1009c580e59f87c0c3e46b503b1a1482cfd9c6e4;hb=003b327529b6d09cad10b6fa3fed6be278add27d;hp=57019215eab51531af8a99c7d0f472ca09bc6c9b;hpb=49fb18fe8d6e6a35ceabe2bce83b26073871e3b0;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 57019215..1009c580 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.7.4
+AbstractPool | poolifier - v2.7.5
  • Preparing search index...
    • -
  • The search index is not available
poolifier - v2.7.4
+
  • The search index is not available
    • poolifier - v2.7.5
    @@ -49,7 +49,7 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:64
    • @@ -202,12 +202,12 @@

    Returns AbstractPool<Worker, Data, Response>

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

    • Properties

    Optional emitter

    -
    emitter?: __module | EventEmitterAsyncResource
    +
    emitter?: EventEmitterAsyncResource

    Event emitter integrated with async resource on which events can be listened to. The async tracking tooling identifier is poolifier:<PoolType>-<WorkerType>-pool.

    Events that can currently be listened to:

    @@ -224,7 +224,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:73

    • Protected Readonly filePath

    filePath: string
    @@ -232,7 +232,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:128

    • Protected Optional Readonly max

    max?: number
    @@ -240,7 +240,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:97

    • Protected Readonly numberOfWorkers

    numberOfWorkers: number
    @@ -248,7 +248,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:127

    • Protected Readonly opts

    opts: PoolOptions<Worker>
    @@ -256,7 +256,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:129

    • Protected promiseResponseMap

    promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    @@ -269,7 +269,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:82

    • Private Readonly startTimestamp

    startTimestamp: number
    @@ -277,7 +277,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:117

    • Private started

    started: boolean
    @@ -285,7 +285,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:109

    • Private starting

    starting: boolean
    @@ -293,7 +293,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:113

    • Private Readonly taskFunctions

    taskFunctions: Map<string, TaskFunction<Data, Response>>
    @@ -305,7 +305,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:104

    • Protected workerChoiceStrategyContext

    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -313,7 +313,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:88

    • Readonly Internal workerNodes

    workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -322,7 +322,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo
    +
  • Defined in src/pools/abstract-pool.ts:70

    • Accessors

    @@ -336,7 +336,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo

    Returns boolean

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

    • Protected full

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

    • info

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

    • Protected maxSize

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

    • Protected minSize

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

    • Private ready

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

    • Protected Abstract type

      @@ -405,7 +405,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo

      Returns "fixed" | "dynamic"

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

    • Private utilization

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

    • Protected Abstract worker

      @@ -428,7 +428,7 @@ The async tracking tooling identifier is poolifier:<PoolType>-<Wo

      Returns "thread" | "cluster"

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

    • Methods

    @@ -461,7 +461,7 @@ If a task function with the same name already exists, it will be overwritten.

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

    • Private addWorkerNode

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

    • Protected afterTaskExecutionHook

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

    • Protected afterWorkerNodeSetup

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

    • Protected beforeTaskExecutionHook

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

    • Private buildTasksQueueOptions

    Returns TasksQueueOptions

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

    • Private checkAndEmitDynamicWorkerCreationEvents

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

    • Private checkAndEmitTaskExecutionEvents

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

    • Private checkAndEmitTaskQueuingEvents

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

    • Private checkMessageWorkerId

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

    • Private checkNumberOfWorkers

      @@ -624,7 +624,7 @@ Can be overridden.

      numberOfWorkers: number

    Returns void

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

    • Private checkPoolOptions

      @@ -637,7 +637,7 @@ Can be overridden.

      opts: PoolOptions<Worker>

    Returns void

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

    • Private checkValidWorkerChoiceStrategyOptions

    Returns void

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

    • Private chooseWorkerNode

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

    • Protected createAndSetupDynamicWorkerNode

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

    • Protected createAndSetupWorkerNode

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

    • Protected Abstract createWorker

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

    • Private deleteTaskFunctionWorkerUsages

      @@ -712,7 +712,7 @@ Can be overridden.

      name: string

    Returns void

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

    • Private dequeueTask

      @@ -725,7 +725,7 @@ Can be overridden.

      workerNodeKey: number

    Returns undefined | Task<Data>

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

    • Protected Abstract deregisterWorkerMessageListener

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

    • destroy

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

    • Protected Abstract destroyWorkerNode

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

    • enableTasksQueue

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

    • Private enqueueTask

      @@ -836,7 +836,7 @@ Can be overridden.

      task: Task<Data>

    Returns number

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

    • execute

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

    • Private executeTask

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

    • Protected flushTasksQueue

      @@ -904,7 +904,7 @@ Can be overridden.

      workerNodeKey: number

    Returns void

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

    • Private flushTasksQueues

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

    • Protected getWorkerInfo

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

    • Private getWorkerNodeKeyByWorker

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

    • Private getWorkerNodeKeyByWorkerId

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

    • Private handleTaskExecutionResponse

      @@ -985,7 +985,7 @@ Can be overridden.

      message: MessageValue<Response, unknown>

    Returns void

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

    • Private handleWorkerReadyResponse

      @@ -998,7 +998,7 @@ Can be overridden.

      message: MessageValue<Response, unknown>

    Returns void

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

    • Private hasBackPressure

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

    • hasTaskFunction

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

    • hasWorkerNodeBackPressure

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

    • Private initializeEventEmitter

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

    • Protected internalBusy

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

    • Protected Abstract isMain

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

    • listTaskFunctionNames

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

    • Private redistributeQueuedTasks

      @@ -1105,7 +1105,7 @@ Can be overridden.

      workerNodeKey: number

    Returns void

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

    • Protected Abstract registerOnceWorkerMessageListener

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

    • Protected Abstract registerWorkerMessageListener

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

    • removeTaskFunction

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

    • Private removeWorkerNode

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

    • Protected sendKillMessageToWorker

      @@ -1238,7 +1238,7 @@ Can be overridden.

      workerNodeKey: number

    Returns Promise<void>

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

    • Protected Abstract sendStartupMessageToWorker

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

    • Private sendStatisticsMessageToWorker

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

    • Private sendTaskFunctionOperationToWorker

      @@ -1291,7 +1291,7 @@ Can be overridden.

      message: MessageValue<Data, unknown>

    Returns Promise<boolean>

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

    • Private sendTaskFunctionOperationToWorkers

      @@ -1304,7 +1304,7 @@ Can be overridden.

      message: MessageValue<Data, unknown>

    Returns Promise<boolean>

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

    • Protected Abstract sendToWorker

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

    • setDefaultTaskFunction

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

    • Private setTaskStealing

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

    • setTasksQueueOptions

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

    • Private setTasksQueueSize

      @@ -1395,7 +1395,7 @@ Can be overridden.

      size: number

    Returns void

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

    • Private setTasksStealingOnBackPressure

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

    • setWorkerChoiceStrategy

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

    • setWorkerChoiceStrategyOptions

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

    • Protected setupHook

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

    • Private shallCreateDynamicWorker

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

    • Private shallExecuteTask

      @@ -1485,7 +1485,7 @@ Can be overridden.

      workerNodeKey: number

    Returns boolean

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

    • Private shallUpdateTaskFunctionWorkerUsage

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

    • start

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

    • Private taskStealingOnEmptyQueue

      @@ -1530,7 +1530,7 @@ Can be overridden.

      workerId: number

    Returns void

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

    • Private tasksQueueSize

      @@ -1543,7 +1543,7 @@ Can be overridden.

      workerNodeKey: number

    Returns number

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

    • Private tasksStealingOnBackPressure

      @@ -1556,7 +1556,7 @@ Can be overridden.

      workerId: number

    Returns void

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

    • Private unsetTaskStealing

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

    • Private unsetTasksStealingOnBackPressure

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

    • Private updateEluWorkerUsage

      @@ -1587,7 +1587,7 @@ Can be overridden.

      message: MessageValue<Response, unknown>

    Returns void

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

    • Private updateRunTimeWorkerUsage

      @@ -1602,7 +1602,7 @@ Can be overridden.

      message: MessageValue<Response, unknown>

    Returns void

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

    • Private updateTaskStatisticsWorkerUsage

      @@ -1617,7 +1617,7 @@ Can be overridden.

      message: MessageValue<Response, unknown>

    Returns void

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

    • Private updateTaskStolenStatisticsWorkerUsage

      @@ -1632,7 +1632,7 @@ Can be overridden.

      taskName: string

    Returns void

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

    • Private updateWaitTimeWorkerUsage

      @@ -1647,7 +1647,7 @@ Can be overridden.

      task: Task<Data>

    Returns void

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

    • Protected workerListener

      @@ -1674,7 +1674,7 @@ Can be overridden.

    +
  • Defined in src/pools/abstract-pool.ts:1495
    • @@ -1791,7 +1791,7 @@ Can be overridden.

  • updateWaitTimeWorkerUsage
  • workerListener
    • -