X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fweighted-round-robin-worker-choice-strategy.ts;h=2b7cd9420d209effcf8fc0b251c805770c30c0b2;hb=6853a353fd0fa3e31ee35cb406775f4868794325;hp=4b1e5382af333d2edb59eb5ae41d1c5132f6ccb3;hpb=d354916afe83118073287bcd405dcdf6f4cd9b20;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 4b1e5382..2b7cd942 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 @@ -7,7 +7,7 @@ import type { RequiredStatistics } from './selection-strategies-types' /** * Virtual task runtime. */ -type TaskRunTime = { +interface TaskRunTime { weight: number runTime: number } @@ -16,16 +16,16 @@ type TaskRunTime = { * Selects the next worker with a weighted round robin scheduling algorithm. * Loosely modeled after the weighted round robin queueing algorithm: https://en.wikipedia.org/wiki/Weighted_round_robin. * - * @template Worker Type of worker which manages the strategy. - * @template Data Type of data sent to the worker. This can only be serializable data. - * @template Response Type of response of execution. This can only be serializable data. + * @typeParam Worker - Type of worker which manages the strategy. + * @typeParam Data - Type of data sent to the worker. This can only be serializable data. + * @typeParam Response - Type of response of execution. This can only be serializable data. */ export class WeightedRoundRobinWorkerChoiceStrategy< Worker extends IPoolWorker, Data, Response > extends AbstractWorkerChoiceStrategy { - /** @inheritDoc */ + /** {@inheritDoc} */ public readonly requiredStatistics: RequiredStatistics = { runTime: true } @@ -42,14 +42,14 @@ export class WeightedRoundRobinWorkerChoiceStrategy< * Per worker virtual task runtime map. */ private readonly workersTaskRunTime: Map = new Map< - Worker, - TaskRunTime + Worker, + TaskRunTime >() /** * Constructs a worker choice strategy that selects with a weighted round robin scheduling algorithm. * - * @param pool The pool instance. + * @param pool - The pool instance. */ public constructor (pool: IPoolInternal) { super(pool) @@ -57,7 +57,7 @@ export class WeightedRoundRobinWorkerChoiceStrategy< this.initWorkersTaskRunTime() } - /** @inheritDoc */ + /** {@inheritDoc} */ public reset (): boolean { this.currentWorkerIndex = 0 this.workersTaskRunTime.clear() @@ -65,13 +65,10 @@ export class WeightedRoundRobinWorkerChoiceStrategy< return true } - /** @inheritDoc */ + /** {@inheritDoc} */ public choose (): Worker { const chosenWorker = this.pool.workers[this.currentWorkerIndex] - if ( - this.isDynamicPool === true && - this.workersTaskRunTime.has(chosenWorker) === false - ) { + if (this.isDynamicPool && !this.workersTaskRunTime.has(chosenWorker)) { this.initWorkerTaskRunTime(chosenWorker) } const workerTaskRunTime =