X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=bf2ac2c251d3052169727dfd6c1bab1d031e7066;hb=cb70b19deb97dc2c8ad1a769e59e870ee37f8e4d;hp=78e7c981b6d9e25efb0c3af38d5cab2c4a3f6014;hpb=b4904890be69e53510b67172dda7b6bbf50a635a;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 78e7c981..bf2ac2c2 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,21 +1,70 @@ -import EventEmitter from 'events' +import EventEmitter from 'node:events' import type { ErrorHandler, ExitHandler, + IWorker, MessageHandler, - OnlineHandler -} from './pool-worker' -import type { WorkerChoiceStrategy } from './selection-strategies/selection-strategies-types' + OnlineHandler, + WorkerNode +} from './worker' +import type { + WorkerChoiceStrategy, + WorkerChoiceStrategyOptions +} from './selection-strategies/selection-strategies-types' + +/** + * Pool types. + * + * @enum + * @internal + */ +export enum PoolType { + /** + * Fixed pool type. + */ + FIXED = 'fixed', + /** + * Dynamic pool type. + */ + DYNAMIC = 'dynamic' +} /** * Pool events emitter. */ export class PoolEmitter extends EventEmitter {} +/** + * Enumeration of pool events. + */ +export const PoolEvents = Object.freeze({ + full: 'full', + busy: 'busy' +} as const) + +/** + * Pool event. + */ +export type PoolEvent = keyof typeof PoolEvents + +/** + * Worker tasks queue options. + */ +export interface TasksQueueOptions { + /** + * Maximum number of tasks that can be executed concurrently on a worker. + * + * @defaultValue 1 + */ + concurrency?: number +} + /** * Options for a poolifier pool. + * + * @typeParam Worker - Type of worker. */ -export interface PoolOptions { +export interface PoolOptions { /** * A function that will listen for message event on each worker. */ @@ -34,46 +83,126 @@ export interface PoolOptions { exitHandler?: ExitHandler /** * The worker choice strategy to use in this pool. + * + * @defaultValue WorkerChoiceStrategies.ROUND_ROBIN */ workerChoiceStrategy?: WorkerChoiceStrategy + /** + * The worker choice strategy options. + */ + workerChoiceStrategyOptions?: WorkerChoiceStrategyOptions /** * Pool events emission. * - * @default true + * @defaultValue true */ enableEvents?: boolean + /** + * Pool worker tasks queue. + * + * @defaultValue false + */ + enableTasksQueue?: boolean + /** + * Pool worker tasks queue options. + */ + tasksQueueOptions?: TasksQueueOptions } /** * Contract definition for a poolifier pool. * - * @template Data Type of data sent to the worker. This can only be serializable data. - * @template Response Type of response of execution. This can only be serializable data. + * @typeParam Worker - Type of worker which manages this pool. + * @typeParam Data - Type of data sent to the worker. This can only be serializable data. + * @typeParam Response - Type of execution response. This can only be serializable data. */ -export interface IPool { +export interface IPool< + Worker extends IWorker, + Data = unknown, + Response = unknown +> { + /** + * Pool type. + * + * If it is `'dynamic'`, it provides the `max` property. + */ + readonly type: PoolType + /** + * Pool worker nodes. + */ + readonly workerNodes: Array> /** * Emitter on which events can be listened to. * * Events that can currently be listened to: * - * - `'busy'` + * - `'full'`: Emitted when the pool is dynamic and full. + * - `'busy'`: Emitted when the pool is busy. */ readonly emitter?: PoolEmitter /** - * Performs the task specified in the constructor with the data parameter. + * Finds the first free worker node key based on the number of tasks the worker has applied. + * + * If a worker is found with `0` running tasks, it is detected as free and its worker node key is returned. + * + * If no free worker is found, `-1` is returned. + * + * @returns A worker node key if there is one, `-1` otherwise. + */ + findFreeWorkerNodeKey: () => number + /** + * Finds the last free worker node key based on the number of tasks the worker has applied. * - * @param data The input for the specified task. This can only be serializable data. - * @returns Promise that will be resolved when the task is successfully completed. + * If a worker is found with `0` running tasks, it is detected as free and its worker node key is returned. + * + * If no free worker is found, `-1` is returned. + * + * @returns A worker node key if there is one, `-1` otherwise. */ - execute(data: Data): Promise + findLastFreeWorkerNodeKey: () => number + /** + * Executes the function specified in the worker constructor with the task data input parameter. + * + * @param data - The task input data for the specified worker function. This can only be serializable data. + * @returns Promise that will be fulfilled when the task is completed. + */ + execute: (data?: Data) => Promise /** * Shutdowns every current worker in this pool. */ - destroy(): Promise + destroy: () => Promise /** * Sets the worker choice strategy in this pool. * - * @param workerChoiceStrategy The worker choice strategy. + * @param workerChoiceStrategy - The worker choice strategy. + * @param workerChoiceStrategyOptions - The worker choice strategy options. + */ + setWorkerChoiceStrategy: ( + workerChoiceStrategy: WorkerChoiceStrategy, + workerChoiceStrategyOptions?: WorkerChoiceStrategyOptions + ) => void + /** + * Sets the worker choice strategy options in this pool. + * + * @param workerChoiceStrategyOptions - The worker choice strategy options. + */ + setWorkerChoiceStrategyOptions: ( + workerChoiceStrategyOptions: WorkerChoiceStrategyOptions + ) => void + /** + * Enables/disables the worker tasks queue in this pool. + * + * @param enable - Whether to enable or disable the worker tasks queue. + * @param tasksQueueOptions - The worker tasks queue options. + */ + enableTasksQueue: ( + enable: boolean, + tasksQueueOptions?: TasksQueueOptions + ) => void + /** + * Sets the worker tasks queue options in this pool. + * + * @param tasksQueueOptions - The worker tasks queue options. */ - setWorkerChoiceStrategy(workerChoiceStrategy: WorkerChoiceStrategy): void + setTasksQueueOptions: (tasksQueueOptions: TasksQueueOptions) => void }