X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-used-worker-choice-strategy.ts;h=e8a7218e160879bcaa97399d78a3b39ff7857bc1;hb=f313c91822165ee5ddf81417df4cad1106f3a4a5;hp=910d10a3ac320db8f3feac42eb43293181a806d1;hpb=9b1068374b1a52479b07e1e22b692289d5579237;p=poolifier.git diff --git a/src/pools/selection-strategies/least-used-worker-choice-strategy.ts b/src/pools/selection-strategies/least-used-worker-choice-strategy.ts index 910d10a3..e8a7218e 100644 --- a/src/pools/selection-strategies/least-used-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-used-worker-choice-strategy.ts @@ -42,8 +42,7 @@ export class LeastUsedWorkerChoiceStrategy< /** @inheritDoc */ public choose (): number { - this.leastUsedNextWorkerNodeKey() - return this.nextWorkerNodeKey + return this.leastUsedNextWorkerNodeKey() } /** @inheritDoc */ @@ -51,7 +50,7 @@ export class LeastUsedWorkerChoiceStrategy< return true } - private leastUsedNextWorkerNodeKey (): void { + private leastUsedNextWorkerNodeKey (): number { let minNumberOfTasks = Infinity for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { const workerTaskStatistics = workerNode.usage.tasks @@ -70,5 +69,6 @@ export class LeastUsedWorkerChoiceStrategy< this.nextWorkerNodeKey = workerNodeKey } } + return this.nextWorkerNodeKey } }