X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=c67d842f1d422de5b07647acb15ad441ecc3dcb8;hb=ccb7d1a70cd9bd4eb050160517e5bc48311d014f;hp=2377e5ef16fdc1a416ee8a3b6d1c857875680190;hpb=396360a789e4806699533ddf899c79dc2b7ae868;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 2377e5ef..c67d842f 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 @@ -113,6 +113,8 @@ setWorkerNodeTasksUsage setupHook tasksQueueSize +updateRunTimeTasksUsage +updateWaitTimeTasksUsage workerListener
    @@ -150,7 +152,7 @@

    Returns AbstractPool<Worker, Data, Response>

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

    @@ -161,32 +163,34 @@
    +
  • Defined in src/pools/abstract-pool.ts:44
  • filePath: string

    Path to the worker file.

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

    Number of workers that this pool should manage.

    +
  • Defined in src/pools/abstract-pool.ts:78
  • opts: PoolOptions<Worker>

    Options for the pool.

    +
  • Defined in src/pools/abstract-pool.ts:80
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Worker, Response>> = ...
    @@ -198,7 +202,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
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -206,7 +210,7 @@

    Default to a round robin algorithm.

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

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

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:336
  • +
  • Defined in src/pools/abstract-pool.ts:329
  • +
  • Defined in src/pools/abstract-pool.ts:230
  • +
  • Defined in src/pools/abstract-pool.ts:220
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:212
  • Methods

    @@ -289,12 +304,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:430
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:554
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:419
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:316
  • +
  • Defined in src/pools/abstract-pool.ts:628
  • Returns void

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

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

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

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

    Returns void

    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:178
  • +
  • Defined in src/pools/abstract-pool.ts:498
  • +
  • Defined in src/pools/abstract-pool.ts:561
  • +
  • Defined in src/pools/abstract-pool.ts:545
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:727
  • +
  • Defined in src/pools/abstract-pool.ts:382
  • Returns void | Promise<void>

    +
  • Defined in src/pools/abstract-pool.ts:396
  • +
  • Defined in src/pools/abstract-pool.ts:294
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:723
  • Returns Promise<Response>

    Promise that will be fulfilled when the task is completed.

    +
  • Defined in src/pools/abstract-pool.ts:347
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:718
  • Returns void

    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:735
  • +
  • Defined in src/pools/abstract-pool.ts:746
  • -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:246
  • +
  • Defined in src/pools/abstract-pool.ts:338
  • +
  • Defined in src/pools/abstract-pool.ts:411
  • +
  • Defined in src/pools/abstract-pool.ts:664
  • Returns void

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:538
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:710
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:527
  • +
  • Defined in src/pools/abstract-pool.ts:306
  • +
  • Defined in src/pools/abstract-pool.ts:253
  • +
  • Defined in src/pools/abstract-pool.ts:283
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:692
  • Returns void

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

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

    Returns void

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

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