X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fless-recently-used-worker-choice-strategy.ts;h=e62d9cdf83bd9a5ae472bc08296dfbe18b96e806;hb=63220255217edbd1d0fd039a0dcb3e141739f43a;hp=33f6859c7776997101262edb552a88ce2a69fd72;hpb=1399f8588a401fd8d4e146da7a31fd6444e31021;p=poolifier.git diff --git a/src/pools/selection-strategies/less-recently-used-worker-choice-strategy.ts b/src/pools/selection-strategies/less-recently-used-worker-choice-strategy.ts index 33f6859c..e62d9cdf 100644 --- a/src/pools/selection-strategies/less-recently-used-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/less-recently-used-worker-choice-strategy.ts @@ -1,19 +1,24 @@ -import type { AbstractPoolWorker } from '../abstract-pool-worker' +import type { IPoolWorker } from '../pool-worker' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' /** * Selects the less recently used worker. * - * @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 LessRecentlyUsedWorkerChoiceStrategy< - Worker extends AbstractPoolWorker, + Worker extends IPoolWorker, Data, Response > extends AbstractWorkerChoiceStrategy { - /** @inheritdoc */ + /** {@inheritDoc} */ + public reset (): boolean { + return true + } + + /** {@inheritDoc} */ public choose (): Worker { let minNumberOfRunningTasks = Infinity // A worker is always found because it picks the one with fewer tasks @@ -22,7 +27,7 @@ export class LessRecentlyUsedWorkerChoiceStrategy< const workerRunningTasks = this.pool.getWorkerRunningTasks( worker ) as number - if (this.isDynamicPool === false && workerRunningTasks === 0) { + if (!this.isDynamicPool && workerRunningTasks === 0) { return worker } else if (workerRunningTasks < minNumberOfRunningTasks) { lessRecentlyUsedWorker = worker