X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=a0e7ee1a35d2620b956eb9e240192754434097f8;hb=a3ae469eebfcc990a251133beb01378599313233;hp=e1d123a994aa77f5d41ce10ccf2a4f3584b6c926;hpb=da3098610d6cf6155bbbe53c84b6ac6ccd400ff5;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 e1d123a9..a0e7ee1a 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -1,25 +1,20 @@ +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 { IWorkerChoiceStrategy, - RequiredStatistics + RequiredStatistics, + WorkerChoiceStrategyOptions } from './selection-strategies-types' -/** - * Worker virtual task timestamp. - */ -interface WorkerVirtualTaskTimestamp { - start: number - end: number -} - /** * Selects the next worker with a fair share scheduling algorithm. * Loosely modeled after the fair queueing algorithm: https://en.wikipedia.org/wiki/Fair_queuing. * * @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 IWorker, @@ -32,20 +27,36 @@ export class FairShareWorkerChoiceStrategy< public readonly requiredStatistics: RequiredStatistics = { runTime: true, avgRunTime: true, - medRunTime: false + medRunTime: false, + waitTime: false, + avgWaitTime: false, + medWaitTime: false, + elu: false } /** - * Worker last virtual task execution timestamp. + * Workers' virtual task end execution timestamp. */ - private readonly workerLastVirtualTaskTimestamp: Map< - number, - WorkerVirtualTaskTimestamp - > = new Map() + private workersVirtualTaskEndTimestamp: number[] = [] + + /** @inheritDoc */ + public constructor ( + pool: IPool, + opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS + ) { + super(pool, opts) + this.setRequiredStatistics(this.opts) + } /** @inheritDoc */ public reset (): boolean { - this.workerLastVirtualTaskTimestamp.clear() + this.workersVirtualTaskEndTimestamp = [] + return true + } + + /** @inheritDoc */ + public update (workerNodeKey: number): boolean { + this.computeWorkerVirtualTaskEndTimestamp(workerNodeKey) return true } @@ -53,15 +64,15 @@ export class FairShareWorkerChoiceStrategy< public choose (): number { let minWorkerVirtualTaskEndTimestamp = Infinity let chosenWorkerNodeKey!: number - for (const [index] of this.pool.workerNodes.entries()) { - this.computeWorkerLastVirtualTaskTimestamp(index) - const workerLastVirtualTaskEndTimestamp = - this.workerLastVirtualTaskTimestamp.get(index)?.end ?? 0 - if ( - workerLastVirtualTaskEndTimestamp < minWorkerVirtualTaskEndTimestamp - ) { - minWorkerVirtualTaskEndTimestamp = workerLastVirtualTaskEndTimestamp - chosenWorkerNodeKey = index + for (const [workerNodeKey] of this.pool.workerNodes.entries()) { + if (this.workersVirtualTaskEndTimestamp[workerNodeKey] == null) { + this.computeWorkerVirtualTaskEndTimestamp(workerNodeKey) + } + const workerVirtualTaskEndTimestamp = + this.workersVirtualTaskEndTimestamp[workerNodeKey] + if (workerVirtualTaskEndTimestamp < minWorkerVirtualTaskEndTimestamp) { + minWorkerVirtualTaskEndTimestamp = workerVirtualTaskEndTimestamp + chosenWorkerNodeKey = workerNodeKey } } return chosenWorkerNodeKey @@ -69,31 +80,36 @@ export class FairShareWorkerChoiceStrategy< /** @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 deleted + this.workersVirtualTaskEndTimestamp.splice(workerNodeKey, 1) + return true } /** - * Computes worker last virtual task timestamp. + * Computes the worker node key virtual task end timestamp. * * @param workerNodeKey - The worker node key. */ - private computeWorkerLastVirtualTaskTimestamp (workerNodeKey: number): void { - const workerVirtualTaskStartTimestamp = Math.max( + private computeWorkerVirtualTaskEndTimestamp (workerNodeKey: number): void { + this.workersVirtualTaskEndTimestamp[workerNodeKey] = + this.getWorkerVirtualTaskEndTimestamp( + workerNodeKey, + this.getWorkerVirtualTaskStartTimestamp(workerNodeKey) + ) + } + + private getWorkerVirtualTaskEndTimestamp ( + workerNodeKey: number, + workerVirtualTaskStartTimestamp: number + ): number { + return ( + workerVirtualTaskStartTimestamp + this.getWorkerTaskRunTime(workerNodeKey) + ) + } + + private getWorkerVirtualTaskStartTimestamp (workerNodeKey: number): number { + return Math.max( performance.now(), - this.workerLastVirtualTaskTimestamp.get(workerNodeKey)?.end ?? -Infinity + this.workersVirtualTaskEndTimestamp[workerNodeKey] ?? -Infinity ) - 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 + (workerVirtualTaskTRunTime ?? 0) - }) } }