X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Fselection-strategies-types.ts;h=f9a504351a4bbbe9d33bddc145c457a7ce27ef78;hb=a20f0ba5aa9c6946254aa197286ad9b70b6a0319;hp=23efd2993d64eefd07087032e8ae39be5c2f0ccd;hpb=737c6d97f8089996a9e30f77104d58afcf5791ba;p=poolifier.git diff --git a/src/pools/selection-strategies/selection-strategies-types.ts b/src/pools/selection-strategies/selection-strategies-types.ts index 23efd299..f9a50435 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. */ @@ -12,6 +10,10 @@ export const WorkerChoiceStrategies = Object.freeze({ * Less used worker selection strategy. */ LESS_USED: 'LESS_USED', + /** + * Less busy worker selection strategy. + */ + LESS_BUSY: 'LESS_BUSY', /** * Fair share worker selection strategy. */ @@ -28,24 +30,41 @@ export const WorkerChoiceStrategies = Object.freeze({ export type WorkerChoiceStrategy = keyof typeof WorkerChoiceStrategies /** - * Pool tasks usage statistics requirements. + * Worker choice strategy options. */ -export interface RequiredStatistics { - runTime: boolean +export interface WorkerChoiceStrategyOptions { + /** + * Use tasks median run time instead of average run time. + */ + medRunTime?: boolean } /** - * Worker choice strategy interface. + * Pool worker tasks usage statistics requirements. * - * @typeParam Worker - Type of worker which manages the strategy. + * @internal */ -export interface IWorkerChoiceStrategy { +export interface RequiredStatistics { + /** + * Require tasks run time. + */ + runTime: boolean /** - * Is the pool attached to the strategy dynamic?. + * Require tasks average run time. */ - readonly isDynamicPool: boolean + avgRunTime: boolean /** - * Required pool tasks usage statistics. + * Require tasks median run time. + */ + medRunTime: boolean +} + +/** + * Worker choice strategy interface. + */ +export interface IWorkerChoiceStrategy { + /** + * Required tasks usage statistics. */ readonly requiredStatistics: RequiredStatistics /** @@ -53,7 +72,19 @@ export interface IWorkerChoiceStrategy { */ reset: () => boolean /** - * Chooses a worker in the pool. + * Chooses a worker node in the pool and returns its key. + */ + choose: () => number + /** + * Removes a worker node key from strategy internals. + * + * @param workerNodeKey - The worker node key. + */ + remove: (workerNodeKey: number) => boolean + /** + * Sets the worker choice strategy options. + * + * @param opts - The worker choice strategy options. */ - choose: () => Worker + setOptions: (opts: WorkerChoiceStrategyOptions) => void }