X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=a337278ba9ce75a074c1b32d751d8f928ec86496;hb=f201a0cd2575be684ab0f291c8590eec538038e0;hp=9ccec752a3f2c68777f2e6473720b3276185a644;hpb=e102732c0e3966b81834b2c0bdd087eb051162ad;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 9ccec752..a337278b 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,9 @@ -import { DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS } from '../../utils' +import { + DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, + DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS +} from '../../utils' import type { IPool } from '../pool' -import type { IWorker } from '../worker' +import type { IWorker, StrategyData } from '../worker' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy' import { type IWorkerChoiceStrategy, @@ -31,11 +34,7 @@ export class FairShareWorkerChoiceStrategy< average: true, median: false }, - waitTime: { - aggregate: false, - average: false, - median: false - }, + waitTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, elu: { aggregate: true, average: true, @@ -43,11 +42,6 @@ export class FairShareWorkerChoiceStrategy< } } - /** - * Workers' virtual task end execution timestamp. - */ - private workersVirtualTaskEndTimestamp: number[] = [] - /** @inheritDoc */ public constructor ( pool: IPool, @@ -59,67 +53,87 @@ export class FairShareWorkerChoiceStrategy< /** @inheritDoc */ public reset (): boolean { - this.workersVirtualTaskEndTimestamp = [] + for (const workerNode of this.pool.workerNodes) { + delete workerNode.strategyData?.virtualTaskEndTimestamp + } return true } /** @inheritDoc */ public update (workerNodeKey: number): boolean { - this.computeWorkerVirtualTaskEndTimestamp(workerNodeKey) + this.pool.workerNodes[workerNodeKey].strategyData = { + virtualTaskEndTimestamp: + this.computeWorkerNodeVirtualTaskEndTimestamp(workerNodeKey) + } return true } /** @inheritDoc */ - public choose (): number { - let minWorkerVirtualTaskEndTimestamp = Infinity - 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 - this.nextWorkerNodeId = workerNodeKey - } - } - return this.nextWorkerNodeId + public choose (): number | undefined { + this.setPreviousWorkerNodeKey(this.nextWorkerNodeKey) + this.nextWorkerNodeKey = this.fairShareNextWorkerNodeKey() + return this.nextWorkerNodeKey } /** @inheritDoc */ - public remove (workerNodeKey: number): boolean { - this.workersVirtualTaskEndTimestamp.splice(workerNodeKey, 1) + public remove (): boolean { return true } + private fairShareNextWorkerNodeKey (): number | undefined { + return this.pool.workerNodes.reduce( + (minWorkerNodeKey, workerNode, workerNodeKey, workerNodes) => { + if (workerNode.strategyData?.virtualTaskEndTimestamp == null) { + workerNode.strategyData = { + virtualTaskEndTimestamp: + this.computeWorkerNodeVirtualTaskEndTimestamp(workerNodeKey) + } + } + return (workerNode.strategyData.virtualTaskEndTimestamp as number) < + ((workerNodes[minWorkerNodeKey].strategyData as StrategyData) + .virtualTaskEndTimestamp as number) + ? workerNodeKey + : minWorkerNodeKey + }, + 0 + ) + } + /** * Computes the worker node key virtual task end timestamp. * * @param workerNodeKey - The worker node key. + * @returns The worker node key virtual task end timestamp. */ - private computeWorkerVirtualTaskEndTimestamp (workerNodeKey: number): void { - this.workersVirtualTaskEndTimestamp[workerNodeKey] = - this.getWorkerVirtualTaskEndTimestamp( - workerNodeKey, - this.getWorkerVirtualTaskStartTimestamp(workerNodeKey) - ) + private computeWorkerNodeVirtualTaskEndTimestamp ( + workerNodeKey: number + ): number { + return this.getWorkerNodeVirtualTaskEndTimestamp( + workerNodeKey, + this.getWorkerNodeVirtualTaskStartTimestamp(workerNodeKey) + ) } - private getWorkerVirtualTaskEndTimestamp ( + private getWorkerNodeVirtualTaskEndTimestamp ( workerNodeKey: number, - workerVirtualTaskStartTimestamp: number + workerNodeVirtualTaskStartTimestamp: number ): number { - const workerTaskRunTime = + const workerNodeTaskRunTime = this.opts.measurement === Measurements.elu - ? this.getWorkerTaskElu(workerNodeKey) - : this.getWorkerTaskRunTime(workerNodeKey) - return workerVirtualTaskStartTimestamp + workerTaskRunTime + ? this.getWorkerNodeTaskElu(workerNodeKey) + : this.getWorkerNodeTaskRunTime(workerNodeKey) + return workerNodeVirtualTaskStartTimestamp + workerNodeTaskRunTime } - private getWorkerVirtualTaskStartTimestamp (workerNodeKey: number): number { - return Math.max( - performance.now(), - this.workersVirtualTaskEndTimestamp[workerNodeKey] ?? -Infinity - ) + private getWorkerNodeVirtualTaskStartTimestamp ( + workerNodeKey: number + ): number { + const virtualTaskEndTimestamp = + this.pool.workerNodes[workerNodeKey]?.strategyData + ?.virtualTaskEndTimestamp + const now = performance.now() + return now < (virtualTaskEndTimestamp ?? -Infinity) + ? (virtualTaskEndTimestamp as number) + : now } }