X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fworker-choice-strategy-context.ts;h=2a487acbdfde0f2d07c2f9eae9233d26da387604;hb=a86b6df187001e7e2e5c248ddb828286f985096c;hp=9a7bb81bd0d83259e9c6b33e86bad7676982eb83;hpb=95ec6006ca39aef0102c82ca42e104a4e9b40b6b;p=poolifier.git diff --git a/src/pools/selection-strategies/worker-choice-strategy-context.ts b/src/pools/selection-strategies/worker-choice-strategy-context.ts index 9a7bb81b..2a487acb 100644 --- a/src/pools/selection-strategies/worker-choice-strategy-context.ts +++ b/src/pools/selection-strategies/worker-choice-strategy-context.ts @@ -40,39 +40,49 @@ export class WorkerChoiceStrategyContext< */ public constructor ( pool: IPool, - /** - * @defaultValue WorkerChoiceStrategies.ROUND_ROBIN - */ private workerChoiceStrategy: WorkerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN, opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS ) { - this.execute.bind(this) + this.execute = this.execute.bind(this) this.workerChoiceStrategies = new Map< WorkerChoiceStrategy, IWorkerChoiceStrategy >([ [ WorkerChoiceStrategies.ROUND_ROBIN, - new RoundRobinWorkerChoiceStrategy(pool, opts) + new (RoundRobinWorkerChoiceStrategy.bind(this))( + pool, + opts + ) ], [ WorkerChoiceStrategies.LESS_USED, - new LessUsedWorkerChoiceStrategy(pool, opts) + new (LessUsedWorkerChoiceStrategy.bind(this))( + pool, + opts + ) ], [ WorkerChoiceStrategies.LESS_BUSY, - new LessBusyWorkerChoiceStrategy(pool, opts) + new (LessBusyWorkerChoiceStrategy.bind(this))( + pool, + opts + ) ], [ WorkerChoiceStrategies.FAIR_SHARE, - new FairShareWorkerChoiceStrategy(pool, opts) - ], - [ - WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN, - new WeightedRoundRobinWorkerChoiceStrategy( + new (FairShareWorkerChoiceStrategy.bind(this))( pool, opts ) + ], + [ + WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN, + new (WeightedRoundRobinWorkerChoiceStrategy.bind(this))< + Worker, + Data, + Response + >(pool, opts) ] ]) }