X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-busy-worker-choice-strategy.ts;h=9a1550e06f60dfecc4339f56ac2c01ad3a7344cf;hb=9768f49f952bcb39789e9b7b5679e1d635cb262d;hp=dabad6826568c38621c73d8fa4f6ac4efb28418f;hpb=9b1068374b1a52479b07e1e22b692289d5579237;p=poolifier.git diff --git a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts index dabad682..9a1550e0 100644 --- a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts @@ -61,8 +61,7 @@ export class LeastBusyWorkerChoiceStrategy< /** @inheritDoc */ public choose (): number { - this.leastBusyNextWorkerNodeKey() - return this.nextWorkerNodeKey + return this.leastBusyNextWorkerNodeKey() } /** @inheritDoc */ @@ -70,7 +69,7 @@ export class LeastBusyWorkerChoiceStrategy< return true } - private leastBusyNextWorkerNodeKey (): void { + private leastBusyNextWorkerNodeKey (): number { let minTime = Infinity for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { const workerTime = @@ -87,5 +86,6 @@ export class LeastBusyWorkerChoiceStrategy< this.nextWorkerNodeKey = workerNodeKey } } + return this.nextWorkerNodeKey } }