X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fpool.ts;h=bb28535b0e732c7eafee9fa353f38166999862e5;hb=2845f2a5555247bbc4e5f6f1059d4f95405a49cd;hp=7c6f6769212c45513453af5d3b373f2b752f4c62;hpb=d33d2d2fed43d102479c38cc28b496872665a90d;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 7c6f6769..bb28535b 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,4 +1,4 @@ -import EventEmitterAsyncResource from 'node:events' +import { EventEmitter } from 'node:events' import type { ErrorHandler, ExitHandler, @@ -47,7 +47,7 @@ export type WorkerType = keyof typeof WorkerTypes /** * Pool events emitter. */ -export class PoolEmitter extends EventEmitterAsyncResource {} +export class PoolEmitter extends EventEmitter {} /** * Enumeration of pool events. @@ -68,13 +68,18 @@ export type PoolEvent = keyof typeof PoolEvents * Pool information. */ export interface PoolInfo { + version: string type: PoolType worker: WorkerType minSize: number maxSize: number - utilization: number + /** Pool utilization ratio. */ + utilization?: number + /** Pool total worker nodes */ workerNodes: number + /** Pool idle worker nodes */ idleWorkerNodes: number + /** Pool busy worker nodes */ busyWorkerNodes: number executedTasks: number executingTasks: number @@ -92,7 +97,7 @@ export interface TasksQueueOptions { * * @defaultValue 1 */ - concurrency?: number + readonly concurrency?: number } /** @@ -189,7 +194,7 @@ export interface IPool< */ execute: (data?: Data, name?: string) => Promise /** - * Terminate every current worker in this pool. + * Terminates every current worker in this pool. */ destroy: () => Promise /**