X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=93e4eda4c8e80aabfc1b13503e87ef4b0dc7173b;hb=f294681c4244effd6671e9d3534bf54bbf122d7a;hp=86f5121dd1d73239c925c51319b6ff8bdc9b2a03;hpb=465b29401ecddad49070d3b0df4e55dc3902788c;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 86f5121d..93e4eda4 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -76,7 +76,7 @@ export interface MeasurementStatistics { /** * Measurement history. */ - history: CircularArray + readonly history: CircularArray } /** @@ -85,8 +85,8 @@ export interface MeasurementStatistics { * @internal */ export interface EventLoopUtilizationMeasurementStatistics { - idle: MeasurementStatistics - active: MeasurementStatistics + readonly idle: MeasurementStatistics + readonly active: MeasurementStatistics utilization: number } @@ -118,6 +118,26 @@ export interface TaskStatistics { failed: number } +/** + * Worker information. + * + * @internal + */ +export interface WorkerInfo { + /** + * Worker id. + */ + readonly id: number | undefined + /** + * Started flag. + */ + started: boolean + /** + * Shared buffer. + */ + readonly sharedBuffer?: Int32Array +} + /** * Worker usage statistics. * @@ -127,19 +147,19 @@ export interface WorkerUsage { /** * Tasks statistics. */ - tasks: TaskStatistics + readonly tasks: TaskStatistics /** * Tasks runtime statistics. */ - runTime: MeasurementStatistics + readonly runTime: MeasurementStatistics /** * Tasks wait time statistics. */ - waitTime: MeasurementStatistics + readonly waitTime: MeasurementStatistics /** * Tasks event loop utilization statistics. */ - elu: EventLoopUtilizationMeasurementStatistics + readonly elu: EventLoopUtilizationMeasurementStatistics } /** @@ -147,7 +167,12 @@ export interface WorkerUsage { */ export interface IWorker { /** - * Register an event listener. + * Worker id. + */ + readonly id?: number + readonly threadId?: number + /** + * Registers an event listener. * * @param event - The event. * @param handler - The event handler. @@ -157,7 +182,7 @@ export interface IWorker { ((event: 'online', handler: OnlineHandler) => void) & ((event: 'exit', handler: ExitHandler) => void) /** - * Register a listener to the exit event that will only be performed once. + * Registers a listener to the exit event that will only be performed once. * * @param event - `'exit'`. * @param handler - The exit handler. @@ -177,6 +202,10 @@ export interface WorkerNode { * Worker node worker. */ readonly worker: Worker + /** + * Worker node worker info. + */ + readonly info: WorkerInfo /** * Worker node worker usage statistics. */