X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=9d18ed70c7cd0d8204c510cfb52f5a774fe831be;hb=ff733df7ebd4813628b27a5d27d509163e12af84;hp=600cb4228b0b33da08a6cea5c13093ca790f1835;hpb=164d950a1bcdc39b4762294c1581e8befbb344e2;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 600cb422..9d18ed70 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -4,7 +4,7 @@ import type { ExitHandler, MessageHandler, OnlineHandler -} from './pool-worker' +} from './worker' import type { WorkerChoiceStrategy } from './selection-strategies/selection-strategies-types' /** @@ -12,6 +12,19 @@ import type { WorkerChoiceStrategy } from './selection-strategies/selection-stra */ 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 + /** * Options for a poolifier pool. */ @@ -42,6 +55,13 @@ export interface PoolOptions { * @defaultValue true */ enableEvents?: boolean + /** + * Pool worker tasks queue. + * + * @experimental + * @defaultValue false + */ + enableTasksQueue?: boolean } /**