X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=56d9dc361fe6e70255877ec6c1e6be6f33b70a70;hb=0567595a23237d7b0e4bc0ec70c8e313eb71bb10;hp=7ef287484f1d00a0002a86a6fd977b99d514e183;hpb=c6bd2650c2690bd84951a2278820adde1b05b41b;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 7ef28748..56d9dc36 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -1,97 +1,114 @@ -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 { 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 IPoolWorker, - Data, - Response + Worker extends IWorker, + Data = unknown, + Response = unknown > extends AbstractWorkerChoiceStrategy implements IWorkerChoiceStrategy { - /** {@inheritDoc} */ + /** @inheritDoc */ public readonly requiredStatistics: RequiredStatistics = { runTime: true, - avgRunTime: true + avgRunTime: true, + medRunTime: false, + waitTime: false, + avgWaitTime: false, + medWaitTime: 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} */ + /** @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 } - /** {@inheritDoc} */ + /** @inheritDoc */ public choose (): number { let minWorkerVirtualTaskEndTimestamp = Infinity - let chosenWorkerKey!: number - for (const [index] of this.pool.workers.entries()) { - this.computeWorkerLastVirtualTaskTimestamp(index) - const workerLastVirtualTaskEndTimestamp = - this.workerLastVirtualTaskTimestamp.get(index)?.end ?? 0 - if ( - workerLastVirtualTaskEndTimestamp < minWorkerVirtualTaskEndTimestamp - ) { - minWorkerVirtualTaskEndTimestamp = workerLastVirtualTaskEndTimestamp - chosenWorkerKey = index + let chosenWorkerNodeKey!: number + 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 chosenWorkerKey + return chosenWorkerNodeKey } - /** {@inheritDoc} */ - public remove (workerKey: number): boolean { - const workerDeleted = this.workerLastVirtualTaskTimestamp.delete(workerKey) - for (const [key, value] of this.workerLastVirtualTaskTimestamp.entries()) { - if (key > workerKey) { - this.workerLastVirtualTaskTimestamp.set(key - 1, value) - } - } - return workerDeleted + /** @inheritDoc */ + public remove (workerNodeKey: number): boolean { + this.workersVirtualTaskEndTimestamp.splice(workerNodeKey, 1) + return true } /** - * Computes worker last virtual task timestamp. + * Computes the worker node key virtual task end timestamp. * - * @param workerKey - The worker key. + * @param workerNodeKey - The worker node key. */ - private computeWorkerLastVirtualTaskTimestamp (workerKey: number): void { - const workerVirtualTaskStartTimestamp = Math.max( - Date.now(), - this.workerLastVirtualTaskTimestamp.get(workerKey)?.end ?? -Infinity + 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.workersVirtualTaskEndTimestamp[workerNodeKey] ?? -Infinity ) - this.workerLastVirtualTaskTimestamp.set(workerKey, { - start: workerVirtualTaskStartTimestamp, - end: - workerVirtualTaskStartTimestamp + - (this.pool.workers[workerKey].tasksUsage.avgRunTime ?? 0) - }) } }