X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=bfd73325c3204d48c656924367500b9f30efbc1d;hb=76d91ea024f25ed0f2ba8d2174bcc3c43fefb02b;hp=6e81112d27e62a532f519411cc72f1cefef80059;hpb=ecdd9f98583c14e55210b00b1cedabf360354709;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 6e81112d..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. */ @@ -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.