X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=3aa9feb70b04d8ea3b321777dd053d9823d994b0;hb=cdaecaee1c7fa5c412daf29f2db41470506793ac;hp=6058a3dea2aa9c0d55ce5f65bba695406a8875c9;hpb=653eba1955b6b3a8beadc40c18595be2b00a088a;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 6058a3de..3aa9feb7 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,7 +1,7 @@ import type { TransferListItem, WorkerOptions } from 'node:worker_threads' import type { EventEmitterAsyncResource } from 'node:events' import type { ClusterSettings } from 'node:cluster' -import type { TaskFunction } from '../worker/task-functions' +import type { TaskFunction } from '../worker/task-functions.js' import type { ErrorHandler, ExitHandler, @@ -10,11 +10,11 @@ import type { MessageHandler, OnlineHandler, WorkerType -} from './worker' +} from './worker.js' import type { WorkerChoiceStrategy, WorkerChoiceStrategyOptions -} from './selection-strategies/selection-strategies-types' +} from './selection-strategies/selection-strategies-types.js' /** * Enumeration of pool types. @@ -69,6 +69,8 @@ export interface PoolInfo { readonly utilization?: number /** Pool total worker nodes. */ readonly workerNodes: number + /** Pool stealing worker nodes. */ + readonly stealingWorkerNodes?: number /** Pool idle worker nodes. */ readonly idleWorkerNodes: number /** Pool busy worker nodes. */ @@ -238,14 +240,6 @@ export interface IPool< * @internal */ readonly workerNodes: Array> - /** - * Whether the worker node has back pressure (i.e. its tasks queue is full). - * - * @param workerNodeKey - The worker node key. - * @returns `true` if the worker node has back pressure, `false` otherwise. - * @internal - */ - readonly hasWorkerNodeBackPressure: (workerNodeKey: number) => boolean /** * Event emitter integrated with async resource on which events can be listened to. * The async tracking tooling identifier is `poolifier:--pool`.