X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=bfd73325c3204d48c656924367500b9f30efbc1d;hb=76d91ea024f25ed0f2ba8d2174bcc3c43fefb02b;hp=14c8dbe1e1d444f5404e8562c1c59ecf1585d869;hpb=023bd558ccd496d78a0ecc281131a6548989865e;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 14c8dbe1..bfd73325 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -96,6 +96,10 @@ export interface TaskStatistics { * Maximum number of queued tasks. */ readonly maxQueued?: number + /** + * Number of stolen tasks. + */ + stolen: number /** * Number of failed tasks. */ @@ -189,7 +193,7 @@ export interface IWorker { /** * Registers a listener to the exit event that will only be performed once. * - * @param event - `'exit'`. + * @param event - The `'exit'` event. * @param handler - The exit handler. */ readonly once: (event: 'exit', handler: ExitHandler) => void @@ -211,14 +215,14 @@ export interface IWorkerNode { * Worker info. */ readonly info: WorkerInfo - /** - * Message channel (worker_threads only). - */ - readonly messageChannel?: MessageChannel /** * Worker usage statistics. */ usage: WorkerUsage + /** + * Message channel (worker_threads only). + */ + readonly messageChannel?: MessageChannel /** * Tasks queue back pressure size. * This is the number of tasks that can be enqueued before the worker node has back pressure.