X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-busy-worker-choice-strategy.ts;h=84476eedaf0c434f5bcce23aa7ca694f1bf9d267;hb=d262e04c193ce648ddd6c0cb1dfaeb9264928c8c;hp=dc304c89fd1e5abecb680aa5d519d9a59f6f18ac;hpb=d33be4309c69e39da5e81479e40b1a5ec7078bd5;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 dc304c89..84476eed 100644 --- a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts @@ -57,6 +57,11 @@ export class LeastBusyWorkerChoiceStrategy< /** @inheritDoc */ public update (): boolean { + return true + } + + /** @inheritDoc */ + public choose (): number { let minTime = Infinity for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { const workerTime = @@ -64,17 +69,12 @@ export class LeastBusyWorkerChoiceStrategy< workerNode.workerUsage.waitTime.aggregate if (workerTime === 0) { this.nextWorkerNodeId = workerNodeKey - return true + break } else if (workerTime < minTime) { minTime = workerTime this.nextWorkerNodeId = workerNodeKey } } - return true - } - - /** @inheritDoc */ - public choose (): number { return this.nextWorkerNodeId }