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=8afd2c36edda1bcb7fe94dcb2b6d1f51c36eac9e;hpb=932fc8be063cc15b543ad14c2ab6df0fa4224fba;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 8afd2c36..84476eed 100644 --- a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts @@ -34,7 +34,11 @@ export class LeastBusyWorkerChoiceStrategy< average: false, median: false }, - elu: false + elu: { + aggregate: false, + average: false, + median: false + } } /** @inheritDoc */ @@ -59,19 +63,19 @@ export class LeastBusyWorkerChoiceStrategy< /** @inheritDoc */ public choose (): number { let minTime = Infinity - let leastBusyWorkerNodeKey!: number for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { const workerTime = workerNode.workerUsage.runTime.aggregate + workerNode.workerUsage.waitTime.aggregate if (workerTime === 0) { - return workerNodeKey + this.nextWorkerNodeId = workerNodeKey + break } else if (workerTime < minTime) { minTime = workerTime - leastBusyWorkerNodeKey = workerNodeKey + this.nextWorkerNodeId = workerNodeKey } } - return leastBusyWorkerNodeKey + return this.nextWorkerNodeId } /** @inheritDoc */