X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fpool-internal.ts;h=6e2850a892d8d63f024e09d6db40e23b43129c06;hb=refs%2Ftags%2Fv2.3.1;hp=f5f1d1908a14d60f2e26f9d6baa75c627468e96b;hpb=bf9549aef8a23a3931e19040dadb7f1e8e6422b5;p=poolifier.git diff --git a/src/pools/pool-internal.ts b/src/pools/pool-internal.ts index f5f1d190..6e2850a8 100644 --- a/src/pools/pool-internal.ts +++ b/src/pools/pool-internal.ts @@ -1,6 +1,6 @@ import EventEmitter from 'events' -import type { AbstractPoolWorker } from './abstract-pool-worker' import type { IPool } from './pool' +import type { IPoolWorker } from './pool-worker' /** * Pool types. @@ -33,7 +33,7 @@ export class PoolEmitter extends EventEmitter {} * @template Response Type of response of execution. */ export interface IPoolInternal< - Worker extends AbstractPoolWorker, + Worker extends IPoolWorker, Data = unknown, Response = unknown > extends IPool { @@ -42,6 +42,14 @@ export interface IPoolInternal< */ readonly workers: Worker[] + /** + * The workers tasks usage map. + * + * `key`: The `Worker` + * `value`: Worker tasks usage statistics. + */ + readonly workersTasksUsage: Map + /** * Emitter on which events can be listened to. * @@ -103,10 +111,10 @@ export interface IPoolInternal< getWorkerRunningTasks(worker: Worker): number | undefined /** - * Get worker average tasks run time. + * Get worker average tasks runtime. * * @param worker The worker. - * @returns The average tasks run time on the worker. + * @returns The average tasks runtime on the worker. */ getWorkerAverageTasksRunTime(worker: Worker): number | undefined }