1 import type EventEmitterAsyncResource from
'node:events';
2 import fs from
'node:fs';
4 import type { PoolInfo
} from
'poolifier';
6 import { WorkerConstants
} from
'./WorkerConstants';
7 import type { SetInfo
, WorkerData
, WorkerOptions
} from
'./WorkerTypes';
9 export abstract class WorkerAbstract
<T
extends WorkerData
> {
10 protected readonly workerScript
: string;
11 protected readonly workerOptions
: WorkerOptions
;
12 public abstract readonly info
: PoolInfo
| SetInfo
;
13 public abstract readonly size
: number;
14 public abstract readonly maxElementsPerWorker
: number | undefined;
15 public abstract readonly emitter
: EventEmitterAsyncResource
| undefined;
18 * `WorkerAbstract` constructor.
20 * @param workerScript -
21 * @param workerOptions -
25 workerOptions
: WorkerOptions
= {
26 workerStartDelay
: WorkerConstants
.DEFAULT_WORKER_START_DELAY
,
27 elementStartDelay
: WorkerConstants
.DEFAULT_ELEMENT_START_DELAY
,
28 poolMinSize
: WorkerConstants
.DEFAULT_POOL_MIN_SIZE
,
29 poolMaxSize
: WorkerConstants
.DEFAULT_POOL_MAX_SIZE
,
30 elementsPerWorker
: WorkerConstants
.DEFAULT_ELEMENTS_PER_WORKER
,
32 messageHandler
: WorkerConstants
.EMPTY_FUNCTION
,
35 if (workerScript
=== null || workerScript
=== undefined) {
36 throw new Error('Worker script is not defined');
38 if (typeof workerScript
=== 'string' && workerScript
.trim().length
=== 0) {
39 throw new Error('Worker script is empty');
41 if (!fs
.existsSync(workerScript
)) {
42 throw new Error('Worker script file does not exist');
44 this.workerScript
= workerScript
;
45 this.workerOptions
= workerOptions
;
49 * Start the worker pool/set.
51 public abstract start(): Promise
<void>;
53 * Stop the worker pool/set.
55 public abstract stop(): Promise
<void>;
57 * Add a task element to the worker pool/set.
59 * @param elementData -
61 public abstract addElement(elementData
: T
): Promise
<void>;