X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=4d6ef2a828fc2b21cd2356886118649e5baacd4f;hb=a20f0ba5aa9c6946254aa197286ad9b70b6a0319;hp=af8eb75d03995d1eb37eeb8daf8d44a8cb6d9d70;hpb=c923ce5670eeae4194aa996d44a1071e88cb21ad;p=poolifier.git diff --git a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts index af8eb75d..4d6ef2a8 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -1,6 +1,12 @@ -import type { IPoolWorker } from '../pool-worker' +import { DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS } from '../../utils' +import type { IPool } from '../pool' +import type { IWorker } from '../worker' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' -import type { RequiredStatistics } from './selection-strategies-types' +import type { + IWorkerChoiceStrategy, + RequiredStatistics, + WorkerChoiceStrategyOptions +} from './selection-strategies-types' /** * Worker virtual task timestamp. @@ -16,37 +22,50 @@ interface WorkerVirtualTaskTimestamp { * * @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 FairShareWorkerChoiceStrategy< - Worker extends IPoolWorker, - Data, - Response -> extends AbstractWorkerChoiceStrategy { - /** {@inheritDoc} */ + Worker extends IWorker, + Data = unknown, + Response = unknown + > + extends AbstractWorkerChoiceStrategy + implements IWorkerChoiceStrategy { + /** @inheritDoc */ public readonly requiredStatistics: RequiredStatistics = { - runTime: true + runTime: true, + avgRunTime: true, + medRunTime: false } /** - * Worker last virtual task execution timestamp. + * Worker last virtual task execution timestamp. */ private readonly workerLastVirtualTaskTimestamp: Map< number, WorkerVirtualTaskTimestamp > = new Map() - /** {@inheritDoc} */ + /** @inheritDoc */ + public constructor ( + pool: IPool, + opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS + ) { + super(pool, opts) + this.checkOptions(this.opts) + } + + /** @inheritDoc */ public reset (): boolean { this.workerLastVirtualTaskTimestamp.clear() return true } - /** {@inheritDoc} */ + /** @inheritDoc */ public choose (): number { let minWorkerVirtualTaskEndTimestamp = Infinity - let chosenWorkerKey!: number - for (const [index] of this.pool.workers.entries()) { + let chosenWorkerNodeKey!: number + for (const [index] of this.pool.workerNodes.entries()) { this.computeWorkerLastVirtualTaskTimestamp(index) const workerLastVirtualTaskEndTimestamp = this.workerLastVirtualTaskTimestamp.get(index)?.end ?? 0 @@ -54,27 +73,39 @@ export class FairShareWorkerChoiceStrategy< workerLastVirtualTaskEndTimestamp < minWorkerVirtualTaskEndTimestamp ) { minWorkerVirtualTaskEndTimestamp = workerLastVirtualTaskEndTimestamp - chosenWorkerKey = index + chosenWorkerNodeKey = index + } + } + return chosenWorkerNodeKey + } + + /** @inheritDoc */ + public remove (workerNodeKey: number): boolean { + const deleted = this.workerLastVirtualTaskTimestamp.delete(workerNodeKey) + for (const [key, value] of this.workerLastVirtualTaskTimestamp.entries()) { + if (key > workerNodeKey) { + this.workerLastVirtualTaskTimestamp.set(key - 1, value) } } - return chosenWorkerKey + return deleted } /** * Computes worker last virtual task timestamp. * - * @param workerKey - The worker key. + * @param workerNodeKey - The worker node key. */ - private computeWorkerLastVirtualTaskTimestamp (workerKey: number): void { + private computeWorkerLastVirtualTaskTimestamp (workerNodeKey: number): void { const workerVirtualTaskStartTimestamp = Math.max( - Date.now(), - this.workerLastVirtualTaskTimestamp.get(workerKey)?.end ?? -Infinity + performance.now(), + this.workerLastVirtualTaskTimestamp.get(workerNodeKey)?.end ?? -Infinity ) - this.workerLastVirtualTaskTimestamp.set(workerKey, { + const workerVirtualTaskTRunTime = this.requiredStatistics.medRunTime + ? this.pool.workerNodes[workerNodeKey].tasksUsage.medRunTime + : this.pool.workerNodes[workerNodeKey].tasksUsage.avgRunTime + this.workerLastVirtualTaskTimestamp.set(workerNodeKey, { start: workerVirtualTaskStartTimestamp, - end: - workerVirtualTaskStartTimestamp + - (this.pool.workers[workerKey].tasksUsage.avgRunTime ?? 0) + end: workerVirtualTaskStartTimestamp + (workerVirtualTaskTRunTime ?? 0) }) } }