X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fworker-options.ts;h=7f9c650694b83c5c1675aa0291f2b312711be522;hb=98f60ddd83d32e108adcfddebeb902f0d5a197eb;hp=97d4a30a59ed3d47503d59fe55eae393f8e52e9f;hpb=df9aaf207bf2e96ed759f9b89fa6573e8c48fb65;p=poolifier.git diff --git a/src/worker/worker-options.ts b/src/worker/worker-options.ts index 97d4a30a..7f9c6506 100644 --- a/src/worker/worker-options.ts +++ b/src/worker/worker-options.ts @@ -1,16 +1,17 @@ /** * Enumeration of kill behaviors. */ -export const KillBehaviors = Object.freeze({ - /** - * If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker **wont** be deleted. - */ - SOFT: 'SOFT', - /** - * If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker will be deleted. - */ - HARD: 'HARD' -} as const) +export const KillBehaviors: Readonly<{ SOFT: 'SOFT', HARD: 'HARD' }> = + Object.freeze({ + /** + * If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker **wont** be deleted. + */ + SOFT: 'SOFT', + /** + * If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker will be deleted. + */ + HARD: 'HARD' + } as const) /** * Kill behavior. @@ -20,14 +21,25 @@ export type KillBehavior = keyof typeof KillBehaviors /** * Handler called when a worker is killed. */ -export type KillHandler = () => void +export type KillHandler = () => void | Promise /** * Options for workers. */ export interface WorkerOptions { /** - * Maximum waiting time in milliseconds for tasks on newly created workers. + * `killBehavior` dictates if your worker will be deleted in case a task is active on it. + * + * - SOFT: If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker **won't** be deleted. + * - HARD: If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker will be deleted. + * + * This option only apply to the newly created workers. + * + * @defaultValue KillBehaviors.SOFT + */ + killBehavior?: KillBehavior + /** + * Maximum waiting time in milliseconds for tasks on newly created workers. It must be greater or equal than 5. * * After this time, newly created workers will be terminated. * The last active time of your worker will be updated when it terminates a task. @@ -39,26 +51,10 @@ export interface WorkerOptions { * @defaultValue 60000 */ maxInactiveTime?: number - /** - * Whether your worker will perform asynchronous or not. - * - * @defaultValue false - * @deprecated This option will be removed in the next major version. - */ - async?: boolean - /** - * `killBehavior` dictates if your worker will be deleted in case a task is active on it. - * - * - SOFT: If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker **won't** be deleted. - * - HARD: If `currentTime - lastActiveTime` is greater than `maxInactiveTime` but a task is still executing or queued, then the worker will be deleted. - * - * This option only apply to the newly created workers. - * - * @defaultValue KillBehaviors.SOFT - */ - killBehavior?: KillBehavior /** * The function to call when a worker is killed. + * + * @defaultValue `() => {}` */ killHandler?: KillHandler }