X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-elu-worker-choice-strategy.ts;h=67a1fdf387a5433999e0b1edcdd70988c6f20d5f;hb=946b809b91118cd7442b90971344e53e15c26466;hp=2624e5b2fdc68444d1e085452fe117655b45f282;hpb=baca80f7921f47ead05d194fb782a3e310f4ea41;p=poolifier.git diff --git a/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts b/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts index 2624e5b2..67a1fdf3 100644 --- a/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts @@ -68,19 +68,14 @@ export class LeastEluWorkerChoiceStrategy< } private leastEluNextWorkerNodeKey (): number | undefined { - let chosenWorkerNodeKey: number | undefined - let minWorkerElu = Infinity - for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { - const workerUsage = workerNode.usage - const workerElu = workerUsage.elu?.active?.aggregate ?? 0 - if (workerElu === 0) { - chosenWorkerNodeKey = workerNodeKey - break - } else if (workerElu < minWorkerElu) { - minWorkerElu = workerElu - chosenWorkerNodeKey = workerNodeKey - } - } - return chosenWorkerNodeKey + return this.pool.workerNodes.reduce( + (minWorkerNodeKey, workerNode, workerNodeKey, workerNodes) => { + return (workerNode.usage.elu?.active?.aggregate ?? 0) < + (workerNodes[minWorkerNodeKey].usage.elu?.active?.aggregate ?? 0) + ? workerNodeKey + : minWorkerNodeKey + }, + 0 + ) } }