X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Fabstract-worker-choice-strategy.ts;h=337b50b1f07eead51a7e6f1dd962bac4654fcc93;hb=ff733df7ebd4813628b27a5d27d509163e12af84;hp=f32229ec3da8550d49263f2ed76a434a63d6d97b;hpb=17393ac83cbf0eacf68ea9efb0a577cc30a5c685;p=poolifier.git diff --git a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts index f32229ec..337b50b1 100644 --- a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts @@ -1,6 +1,6 @@ import type { IPoolInternal } from '../pool-internal' import { PoolType } from '../pool-internal' -import type { IPoolWorker } from '../pool-worker' +import type { IWorker } from '../worker' import type { IWorkerChoiceStrategy, RequiredStatistics @@ -14,16 +14,17 @@ import type { * @typeParam Response - Type of response of execution. This can only be serializable data. */ export abstract class AbstractWorkerChoiceStrategy< - Worker extends IPoolWorker, + Worker extends IWorker, Data = unknown, Response = unknown > implements IWorkerChoiceStrategy { /** @inheritDoc */ - public readonly isDynamicPool: boolean + protected readonly isDynamicPool: boolean /** @inheritDoc */ public requiredStatistics: RequiredStatistics = { runTime: false, - avgRunTime: false + avgRunTime: false, + medRunTime: false } /** @@ -32,7 +33,7 @@ export abstract class AbstractWorkerChoiceStrategy< * @param pool - The pool instance. */ public constructor ( - public readonly pool: IPoolInternal + protected readonly pool: IPoolInternal ) { this.isDynamicPool = this.pool.type === PoolType.DYNAMIC this.choose.bind(this) @@ -45,5 +46,5 @@ export abstract class AbstractWorkerChoiceStrategy< public abstract choose (): number /** @inheritDoc */ - public abstract remove (workerKey: number): boolean + public abstract remove (workerNodeKey: number): boolean }