X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fweighted-round-robin-worker-choice-strategy.ts;h=24a25b4d30de7fa553f500615b5b5e8e06efd972;hb=5502c07c81463257e1dd3015ee5a828846ece0b2;hp=2b7cd9420d209effcf8fc0b251c805770c30c0b2;hpb=38e795c12f0e9daeff7b025147f36f85f486366e;p=poolifier.git diff --git a/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts index 2b7cd942..24a25b4d 100644 --- a/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts @@ -1,4 +1,4 @@ -import { cpus } from 'os' +import { cpus } from 'node:os' import type { IPoolInternal } from '../pool-internal' import type { IPoolWorker } from '../pool-worker' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' @@ -31,9 +31,9 @@ export class WeightedRoundRobinWorkerChoiceStrategy< } /** - * Worker index where the current task will be submitted. + * Worker id where the current task will be submitted. */ - private currentWorkerIndex: number = 0 + private currentWorkerId: number = 0 /** * Default worker weight. */ @@ -41,8 +41,8 @@ export class WeightedRoundRobinWorkerChoiceStrategy< /** * Per worker virtual task runtime map. */ - private readonly workersTaskRunTime: Map = new Map< - Worker, + private readonly workersTaskRunTime: Map = new Map< + number, TaskRunTime >() @@ -59,67 +59,80 @@ export class WeightedRoundRobinWorkerChoiceStrategy< /** {@inheritDoc} */ public reset (): boolean { - this.currentWorkerIndex = 0 + this.currentWorkerId = 0 this.workersTaskRunTime.clear() this.initWorkersTaskRunTime() return true } /** {@inheritDoc} */ - public choose (): Worker { - const chosenWorker = this.pool.workers[this.currentWorkerIndex] - if (this.isDynamicPool && !this.workersTaskRunTime.has(chosenWorker)) { - this.initWorkerTaskRunTime(chosenWorker) + public choose (): number { + const chosenWorkerKey = this.currentWorkerId + if (this.isDynamicPool && !this.workersTaskRunTime.has(chosenWorkerKey)) { + this.initWorkerTaskRunTime(chosenWorkerKey) } const workerTaskRunTime = - this.workersTaskRunTime.get(chosenWorker)?.runTime ?? 0 + this.workersTaskRunTime.get(chosenWorkerKey)?.runTime ?? 0 const workerTaskWeight = - this.workersTaskRunTime.get(chosenWorker)?.weight ?? + this.workersTaskRunTime.get(chosenWorkerKey)?.weight ?? this.defaultWorkerWeight if (workerTaskRunTime < workerTaskWeight) { this.setWorkerTaskRunTime( - chosenWorker, + chosenWorkerKey, workerTaskWeight, workerTaskRunTime + - (this.getWorkerVirtualTaskRunTime(chosenWorker) ?? 0) + (this.getWorkerVirtualTaskRunTime(chosenWorkerKey) ?? 0) ) } else { - this.currentWorkerIndex = - this.currentWorkerIndex === this.pool.workers.length - 1 + this.currentWorkerId = + this.currentWorkerId === this.pool.workers.length - 1 ? 0 - : this.currentWorkerIndex + 1 - this.setWorkerTaskRunTime( - this.pool.workers[this.currentWorkerIndex], - workerTaskWeight, - 0 - ) + : this.currentWorkerId + 1 + this.setWorkerTaskRunTime(this.currentWorkerId, workerTaskWeight, 0) + } + return chosenWorkerKey + } + + /** {@inheritDoc} */ + public remove (workerKey: number): boolean { + if (this.currentWorkerId === workerKey) { + this.currentWorkerId = + this.currentWorkerId > this.pool.workers.length - 1 + ? this.pool.workers.length - 1 + : this.currentWorkerId + } + const workerDeleted = this.workersTaskRunTime.delete(workerKey) + for (const [key, value] of this.workersTaskRunTime) { + if (key > workerKey) { + this.workersTaskRunTime.set(key - 1, value) + } } - return chosenWorker + return workerDeleted } private initWorkersTaskRunTime (): void { - for (const worker of this.pool.workers) { - this.initWorkerTaskRunTime(worker) + for (const [index] of this.pool.workers.entries()) { + this.initWorkerTaskRunTime(index) } } - private initWorkerTaskRunTime (worker: Worker): void { - this.setWorkerTaskRunTime(worker, this.defaultWorkerWeight, 0) + private initWorkerTaskRunTime (workerKey: number): void { + this.setWorkerTaskRunTime(workerKey, this.defaultWorkerWeight, 0) } private setWorkerTaskRunTime ( - worker: Worker, + workerKey: number, weight: number, runTime: number ): void { - this.workersTaskRunTime.set(worker, { + this.workersTaskRunTime.set(workerKey, { weight, runTime }) } - private getWorkerVirtualTaskRunTime (worker: Worker): number | undefined { - return this.pool.getWorkerAverageTasksRunTime(worker) + private getWorkerVirtualTaskRunTime (workerKey: number): number { + return this.pool.workers[workerKey].tasksUsage.avgRunTime } private computeWorkerWeight (): number {