X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fweighted-round-robin-worker-choice-strategy.ts;h=53b2d64d923412e73ae11f9b8cbc23f892acdf4a;hb=65d7a1c9177d558c01570f4013b7aa23bbee952d;hp=f4bac5d76c4e3b669bb5720b99c03b07eabc577d;hpb=bb3f9b66fa2241864d31937eeced22caab83d17e;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 f4bac5d7..53b2d64d 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,12 +1,13 @@ import { cpus } from 'node:os' import type { IWorker } from '../worker' +import type { IPool } from '../pool' +import { DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS } from '../../utils' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' import type { IWorkerChoiceStrategy, RequiredStatistics, WorkerChoiceStrategyOptions } from './selection-strategies-types' -import type { IPool } from '../pool' /** * Virtual task runtime. @@ -22,7 +23,7 @@ interface TaskRunTime { * * @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. + * @typeParam Response - Type of execution response. This can only be serializable data. */ export class WeightedRoundRobinWorkerChoiceStrategy< Worker extends IWorker, @@ -54,17 +55,13 @@ export class WeightedRoundRobinWorkerChoiceStrategy< TaskRunTime >() - /** - * Constructs a worker choice strategy that selects with a weighted round robin scheduling algorithm. - * - * @param pool - The pool instance. - * @param opts - The worker choice strategy options. - */ + /** @inheritDoc */ public constructor ( pool: IPool, - opts?: WorkerChoiceStrategyOptions + opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS ) { super(pool, opts) + this.checkOptions(this.opts) this.defaultWorkerWeight = this.computeWorkerWeight() this.initWorkersTaskRunTime() }