X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=4a399b49991b2af364cf7c25c8cc38b57d69c1d4;hb=2c94c3a5da9d6b4a0ac992386907d8a406ee38f7;hp=5b462f28736b673922d89353e198367cc9545b22;hpb=3a592a1254b999797590d1b54662b747eed17528;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 5b462f28..4a399b49 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -45,7 +45,7 @@ +
  • Defined in src/pools/abstract-pool.ts:35
    • @@ -71,6 +71,7 @@ full numberOfQueuedTasks numberOfRunningTasks +size type
    @@ -85,6 +86,7 @@ checkPoolOptions checkValidTasksQueueOptions checkValidWorkerChoiceStrategy +checkValidWorkerChoiceStrategyOptions chooseWorkerNode createAndSetupWorker createWorker @@ -96,10 +98,8 @@ execute executeTask flushTasksQueue -flushTasksQueueByWorker flushTasksQueues getWorkerNodeKey -getWorkerTasksUsage internalBusy isMain pushWorkerNode @@ -150,7 +150,7 @@

    Returns AbstractPool<Worker, Data, Response>

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

    • Properties

    @@ -165,28 +165,28 @@
    +
  • Defined in src/pools/abstract-pool.ts:44

    • Readonly filePath

    filePath: string

    Path to the worker file.

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

    • Readonly numberOfWorkers

    numberOfWorkers: number

    Number of workers that this pool should manage.

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

    • Readonly opts

    opts: PoolOptions<Worker>

    Options for the pool.

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

    • Protected promiseResponseMap

    promiseResponseMap: Map<string, PromiseResponseWrapper<Worker, Response>> = ...
    @@ -198,7 +198,7 @@

    When we receive a message from the worker, we get a map entry with the promise resolve/reject bound to the message id.

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

    • Protected workerChoiceStrategyContext

    workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -206,7 +206,7 @@

    Default to a round robin algorithm.

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

    • Readonly workerNodes

    workerNodes: WorkerNode<Worker, Data>[] = []
    @@ -214,7 +214,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:41

    • Accessors

    @@ -227,7 +227,7 @@

    Returns boolean

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

    • Protected Abstract full

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

    • Private numberOfQueuedTasks

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

    • Private numberOfRunningTasks

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

    Abstract size

    +

    Abstract type

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

    • Methods

    @@ -289,12 +300,12 @@ Can be overridden.

    The worker.

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

    The received message.

    • Returns void

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

    • Protected Abstract afterWorkerSetup

    Returns void

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

    • Protected beforeTaskExecutionHook

    Returns void

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

    • Private buildTasksQueueOptions

    Returns TasksQueueOptions

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

    • Private checkAndEmitEvents

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

    • Private checkFilePath

    Returns void

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

    • Private checkNumberOfWorkers

    Returns void

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

    • Private checkPoolOptions

    Returns void

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

    • Private checkValidTasksQueueOptions

    Returns void

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

    • Private checkValidWorkerChoiceStrategy

    Returns void

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

    Private checkValidWorkerChoiceStrategyOptions

    +

    Protected chooseWorkerNode

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

    • Protected createAndSetupWorker

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

    • Protected Abstract createWorker

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

    • Private dequeueTask

    Returns undefined | Task<Data>

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

    • destroy

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

    • Protected Abstract destroyWorker

    Returns void | Promise<void>

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

    • enableTasksQueue

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

    • Private enqueueTask

    Returns number

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

    • execute

    Returns Promise<Response>

    Promise that will be fulfilled when the task is completed.

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

    • Private executeTask

    Returns void

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

    • Private flushTasksQueue

    Returns void

    -
    -

    Private flushTasksQueueByWorker

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

    • Private flushTasksQueues

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

    • Private getWorkerNodeKey

    -
    -

    Private getWorkerTasksUsage

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

    • Protected internalBusy

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

    • Protected Abstract isMain

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

    • Private pushWorkerNode

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

    • Protected Abstract registerWorkerMessageListener

    Returns void

    Returns void

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

    • Private removeWorkerNode

    Returns void

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

    • Protected Abstract sendToWorker

    Returns void

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

    • setTasksQueueOptions

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

    • setWorkerChoiceStrategy

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

    • setWorkerChoiceStrategyOptions

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

    • Private setWorkerNode

    Returns void

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

    • Private setWorkerNodeTasksUsage

    Returns void

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

    • Protected setupHook

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

    • Private tasksQueueSize

    Returns number

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

    • Protected workerListener

    Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:532
    • @@ -933,6 +928,7 @@ Can be overridden

  • full
  • numberOfQueuedTasks
  • numberOfRunningTasks
    • +
  • size
  • type
  • afterTaskExecutionHook
  • afterWorkerSetup
    • @@ -944,6 +940,7 @@ Can be overridden

  • checkPoolOptions
  • checkValidTasksQueueOptions
  • checkValidWorkerChoiceStrategy
    • +
  • checkValidWorkerChoiceStrategyOptions
  • chooseWorkerNode
  • createAndSetupWorker
  • createWorker
    • @@ -955,10 +952,8 @@ Can be overridden

  • execute
  • executeTask
  • flushTasksQueue
    • -
  • flushTasksQueueByWorker
  • flushTasksQueues
  • getWorkerNodeKey
    • -
  • getWorkerTasksUsage
  • internalBusy
  • isMain
  • pushWorkerNode
    • @@ -1010,6 +1005,7 @@ Can be overridden

  • MessageHandler
  • OnlineHandler
  • PoolEvent
    • +
  • TaskFunctions
  • ThreadWorkerWithMessageChannel
  • WorkerAsyncFunction
  • WorkerChoiceStrategy