X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=2cdf9b748db6350b0bfa7c9e64aedd8b32b296cf;hb=243a550a93e278669fe5602aeba92dc8ba11260e;hp=e9a093fad6c0287f68f1758a5bc4902d80383317;hpb=bdede008ae867784cd6dfa7468a930d7c026177b;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index e9a093fa..2cdf9b74 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,15 +1,50 @@ +import EventEmitter from 'node:events' import type { ErrorHandler, ExitHandler, + IWorker, MessageHandler, OnlineHandler -} from './pool-worker' -import type { WorkerChoiceStrategy } from './selection-strategies/selection-strategies-types' +} from './worker' +import type { + WorkerChoiceStrategy, + WorkerChoiceStrategyOptions +} from './selection-strategies/selection-strategies-types' + +/** + * 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. */ -export interface PoolOptions { +export interface PoolOptions { /** * A function that will listen for message event on each worker. */ @@ -27,39 +62,66 @@ export interface PoolOptions { */ exitHandler?: ExitHandler /** - * The work choice strategy to use in this pool. + * The worker choice strategy to use in this pool. */ workerChoiceStrategy?: WorkerChoiceStrategy + /** + * The worker choice strategy options. + */ + workerChoiceStrategyOptions?: WorkerChoiceStrategyOptions /** * Pool events emission. * - * @default true + * @defaultValue true */ enableEvents?: boolean + /** + * Pool worker tasks queue. + * + * @experimental + * @defaultValue false + */ + enableTasksQueue?: boolean + /** + * Pool worker tasks queue options. + * + * @experimental + * @defaultValue \{ concurrency: 1 \} + */ + 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 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. */ export interface IPool { + /** + * Emitter on which events can be listened to. + * + * Events that can currently be listened to: + * + * - `'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. * - * @param data The input for the specified task. This can only be serializable data. + * @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. */ - execute(data: Data): Promise + 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. */ - setWorkerChoiceStrategy(workerChoiceStrategy: WorkerChoiceStrategy): void + setWorkerChoiceStrategy: (workerChoiceStrategy: WorkerChoiceStrategy) => void }