X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fselection-strategies-types.ts;h=23dc5e8c9a4e744ed605beeaaca1b38b4e2d944d;hb=1b0aa06b3ab5cf8ae8bd135087143165889901cc;hp=f875c2906ee3a173ffab6790d93aece511b2a0ef;hpb=ea7a90d36354a4e1c833271571c6f3eb80428600;p=poolifier.git diff --git a/src/pools/selection-strategies/selection-strategies-types.ts b/src/pools/selection-strategies/selection-strategies-types.ts index f875c290..23dc5e8c 100644 --- a/src/pools/selection-strategies/selection-strategies-types.ts +++ b/src/pools/selection-strategies/selection-strategies-types.ts @@ -1,5 +1,3 @@ -import type { IPoolWorker } from '../pool-worker' - /** * Enumeration of worker choice strategies. */ @@ -9,9 +7,13 @@ export const WorkerChoiceStrategies = Object.freeze({ */ ROUND_ROBIN: 'ROUND_ROBIN', /** - * Less recently used worker selection strategy. + * Less used worker selection strategy. + */ + LESS_USED: 'LESS_USED', + /** + * Less busy worker selection strategy. */ - LESS_RECENTLY_USED: 'LESS_RECENTLY_USED', + LESS_BUSY: 'LESS_BUSY', /** * Fair share worker selection strategy. */ @@ -28,32 +30,44 @@ export const WorkerChoiceStrategies = Object.freeze({ export type WorkerChoiceStrategy = keyof typeof WorkerChoiceStrategies /** - * Pool tasks usage statistics requirements. + * Worker choice strategy options. */ -export type RequiredStatistics = { +export interface WorkerChoiceStrategyOptions { + /** + * Use tasks median run time instead of average run time. + */ + medRunTime?: boolean +} + +/** + * Pool worker tasks usage statistics requirements. + */ +export interface RequiredStatistics { runTime: boolean + avgRunTime: boolean + medRunTime: boolean } /** * Worker choice strategy interface. - * - * @template Worker Type of worker which manages the strategy. */ -export interface IWorkerChoiceStrategy { +export interface IWorkerChoiceStrategy { /** - * Is the pool attached to the strategy dynamic?. + * Required tasks usage statistics. */ - readonly isDynamicPool: boolean + readonly requiredStatistics: RequiredStatistics /** - * Required pool tasks usage statistics. + * Resets strategy internals (counters, statistics, etc.). */ - readonly requiredStatistics: RequiredStatistics + reset: () => boolean /** - * Resets strategy internal statistics. + * Chooses a worker node in the pool and returns its key. */ - resetStatistics(): boolean + choose: () => number /** - * Chooses a worker in the pool. + * Removes a worker node key from strategy internals. + * + * @param workerNodeKey - The worker node key. */ - choose(): Worker + remove: (workerNodeKey: number) => boolean }