X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fround-robin-worker-choice-strategy.ts;h=a23275873909b0731cb3d514af74f0b9fb59090a;hb=e65c6cd9a3d6ed2e5b8af95120a5aa070101e945;hp=0a9fbb7b0a386e1f2ec2f7a78c8f0bf61a9d8572;hpb=a6f7f1b40b3591b19a58f69b22e751c4c4311522;p=poolifier.git diff --git a/src/pools/selection-strategies/round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/round-robin-worker-choice-strategy.ts index 0a9fbb7b..a2327587 100644 --- a/src/pools/selection-strategies/round-robin-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/round-robin-worker-choice-strategy.ts @@ -4,9 +4,9 @@ import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' /** * Selects the next worker in a round robin fashion. * - * @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 RoundRobinWorkerChoiceStrategy< Worker extends IPoolWorker, @@ -14,23 +14,23 @@ export class RoundRobinWorkerChoiceStrategy< Response > extends AbstractWorkerChoiceStrategy { /** - * Index for the next worker. + * Id of the next worker. */ - private nextWorkerIndex: number = 0 + private nextWorkerId: number = 0 - /** @inheritDoc */ + /** {@inheritDoc} */ public reset (): boolean { - this.nextWorkerIndex = 0 + this.nextWorkerId = 0 return true } - /** @inheritDoc */ + /** {@inheritDoc} */ public choose (): Worker { - const chosenWorker = this.pool.workers[this.nextWorkerIndex] - this.nextWorkerIndex = - this.nextWorkerIndex === this.pool.workers.length - 1 + const chosenWorker = this.pool.workers[this.nextWorkerId]?.worker + this.nextWorkerId = + this.nextWorkerId === this.pool.workers.length - 1 ? 0 - : this.nextWorkerIndex + 1 + : this.nextWorkerId + 1 return chosenWorker } }