1 import fs from
'node:fs';
3 import { WorkerConstants
} from
'./WorkerConstants';
4 import type { WorkerData
, WorkerOptions
} from
'./WorkerTypes';
6 export abstract class WorkerAbstract
<T
extends WorkerData
> {
7 protected readonly workerScript
: string;
8 protected readonly workerOptions
: WorkerOptions
;
9 public abstract readonly size
: number;
10 public abstract readonly maxElementsPerWorker
: number | undefined;
13 * `WorkerAbstract` constructor.
15 * @param workerScript -
16 * @param workerOptions -
20 workerOptions
: WorkerOptions
= {
21 workerStartDelay
: WorkerConstants
.DEFAULT_WORKER_START_DELAY
,
22 elementStartDelay
: WorkerConstants
.DEFAULT_ELEMENT_START_DELAY
,
23 poolMinSize
: WorkerConstants
.DEFAULT_POOL_MIN_SIZE
,
24 poolMaxSize
: WorkerConstants
.DEFAULT_POOL_MAX_SIZE
,
25 elementsPerWorker
: WorkerConstants
.DEFAULT_ELEMENTS_PER_WORKER
,
27 messageHandler
: WorkerConstants
.EMPTY_FUNCTION
,
30 if (workerScript
=== null || workerScript
=== undefined) {
31 throw new Error('Worker script is not defined');
33 if (typeof workerScript
=== 'string' && workerScript
.trim().length
=== 0) {
34 throw new Error('Worker script is empty');
36 if (!fs
.existsSync(workerScript
)) {
37 throw new Error('Worker script file does not exist');
39 this.workerScript
= workerScript
;
40 this.workerOptions
= workerOptions
;
43 public abstract start(): Promise
<void>;
44 public abstract stop(): Promise
<void>;
45 public abstract addElement(elementData
: T
): Promise
<void>;