X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=86fada26adb28db38824ca5ecf87c2b5d236b18c;hb=ef29303558d4caf5ff412db9579ea28346b77f3f;hp=aff9850dd46ceb55e6088a5de0ea9e4d8b744410;hpb=e907c7098316b8b10928c2a716626c710457ae27;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index aff9850d..86fada26 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,13 +1,13 @@ -AbstractPool | poolifier - v2.6.32
+AbstractPool | poolifier - v2.6.45
-
+
  • The search index is not available
  • poolifier - v2.6.45 +
    @@ -49,19 +49,19 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:59
  • - +

    Constructors

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

    @@ -198,9 +201,9 @@

    Events that can currently be listened to:

    • 'ready': Emitted when the number of workers created in the pool has reached the minimum size expected and are ready.
    • -
    • 'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing at least one task.
    • +
    • 'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing concurrently their tasks quota.
    • 'full': Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected.
    • -
    • 'destroy': Emitted when the pool is destroyed.
    • +
    • 'destroy': Emitted when the pool is destroyed.
    • 'error': Emitted when an uncaught error occurs.
    • 'taskError': Emitted when an error occurs while executing a task.
    • 'backPressure': Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size >= maximum queue size).
    • @@ -209,7 +212,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:68
  • filePath: string
    @@ -217,7 +220,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:116
  • max?: number
    @@ -225,7 +228,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:92
  • numberOfWorkers: number
    @@ -233,7 +236,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:115
  • opts: PoolOptions<Worker>
    @@ -241,11 +244,11 @@
    +
  • Defined in src/pools/abstract-pool.ts:117
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    -

    The task execution response promise map.

    +

    The task execution response promise map:

    • key: The message id of each submitted task.
    • value: An object that contains the worker, the execution response promise resolve and reject callbacks.
    • @@ -254,7 +257,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:77
  • startTimestamp: number
    @@ -262,7 +265,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:105
  • started: boolean
    @@ -270,15 +273,15 @@
    +
  • Defined in src/pools/abstract-pool.ts:97
  • - +
    starting: boolean

    Whether the pool is starting or not.

    +
  • Defined in src/pools/abstract-pool.ts:101
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -286,7 +289,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:83
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -295,7 +298,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:65
  • Accessors

    @@ -309,7 +312,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:685
  • +
  • Defined in src/pools/abstract-pool.ts:676
  • +
  • Defined in src/pools/abstract-pool.ts:334
  • +
  • Defined in src/pools/abstract-pool.ts:547
  • +
  • Defined in src/pools/abstract-pool.ts:540
  • +
  • Defined in src/pools/abstract-pool.ts:492
  • +
  • Defined in src/pools/abstract-pool.ts:530
  • +
  • Defined in src/pools/abstract-pool.ts:509
  • +
  • Defined in src/pools/abstract-pool.ts:535
  • Methods

    @@ -425,7 +428,7 @@

    Throws

    https://nodejs.org/api/errors.html#class-error If the added worker node is not found.

    +
  • Defined in src/pools/abstract-pool.ts:1423
  • +
  • Defined in src/pools/abstract-pool.ts:889
  • +
  • Defined in src/pools/abstract-pool.ts:1163
  • +
  • Defined in src/pools/abstract-pool.ts:859
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:657
  • +
  • Defined in src/pools/abstract-pool.ts:1398
  • +
  • Defined in src/pools/abstract-pool.ts:1386
  • +
  • Defined in src/pools/abstract-pool.ts:1392
  • Returns void

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

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

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:252
  • +
  • Defined in src/pools/abstract-pool.ts:1016
  • +
  • Defined in src/pools/abstract-pool.ts:1106
  • +
  • Defined in src/pools/abstract-pool.ts:1062
  • +
  • Defined in src/pools/abstract-pool.ts:1055
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1488
  • +
  • Defined in src/pools/abstract-pool.ts:804
  • +
  • Defined in src/pools/abstract-pool.ts:835
  • +
  • Defined in src/pools/abstract-pool.ts:628
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1482
  • +
  • Defined in src/pools/abstract-pool.ts:733
  • +
  • Defined in src/pools/abstract-pool.ts:1476
  • Returns void

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

    Returns undefined | WorkerInfo

    The worker information.

    +

    Returns WorkerInfo

    The worker information.

    +
  • Defined in src/pools/abstract-pool.ts:1412
  • +
  • Defined in src/pools/abstract-pool.ts:576
  • +
  • Defined in src/pools/abstract-pool.ts:588
  • Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:1344
  • +
  • Defined in src/pools/abstract-pool.ts:1461
  • +
  • Defined in src/pools/abstract-pool.ts:1454
  • +
  • Defined in src/pools/abstract-pool.ts:692
  • +
  • Defined in src/pools/abstract-pool.ts:850
  • +
  • Defined in src/pools/abstract-pool.ts:712
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1207
  • +
  • Defined in src/pools/abstract-pool.ts:1150
  • +
  • Defined in src/pools/abstract-pool.ts:1445
  • Returns Promise<void>

    +
  • Defined in src/pools/abstract-pool.ts:814
  • +
  • Defined in src/pools/abstract-pool.ts:1187
  • +
  • Defined in src/pools/abstract-pool.ts:1194
  • -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:1044
  • +
  • Defined in src/pools/abstract-pool.ts:640
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:595
  • +
  • Defined in src/pools/abstract-pool.ts:614
  • +
  • Defined in src/pools/abstract-pool.ts:843
  • +
  • Defined in src/pools/abstract-pool.ts:1033
  • +
    + +
    -
    - +
  • Defined in src/pools/abstract-pool.ts:922
  • +
    + +
    +
    +
    +
  • Defined in src/pools/abstract-pool.ts:1251
  • Returns number

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

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

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

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

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

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:963
  • +
  • Defined in src/pools/abstract-pool.ts:1326
  • @@ -1490,84 +1538,49 @@ Can be overridden.

  • sendStartupMessageToWorker
  • sendStatisticsMessageToWorker
  • sendToWorker
  • -
  • setTasksQueueMaxSize
  • setTasksQueueOptions
  • +
  • setTasksQueueSize
  • setWorkerChoiceStrategy
  • setWorkerChoiceStrategyOptions
  • setupHook
  • shallCreateDynamicWorker
  • +
  • shallExecuteTask
  • shallUpdateTaskFunctionWorkerUsage
  • -
  • startPool
  • +
  • start
  • +
  • taskStealingOnEmptyQueue
  • tasksQueueSize
  • tasksStealingOnBackPressure
  • updateEluWorkerUsage
  • updateRunTimeWorkerUsage
  • updateTaskStatisticsWorkerUsage
  • +
  • updateTaskStolenStatisticsWorkerUsage
  • updateWaitTimeWorkerUsage
  • workerListener
  • +
    -

    Generated using TypeDoc

    -
    \ No newline at end of file +

    Generated using TypeDoc

    +
    \ No newline at end of file