build(deps): apply updates
[e-mobility-charging-stations-simulator.git] / src / worker / WorkerDynamicPool.ts
CommitLineData
962a8159 1import type EventEmitterAsyncResource from 'node:events';
01f4001e 2import type { Worker } from 'node:worker_threads';
0e4fa348
JB
3
4import { DynamicThreadPool, type ErrorHandler, type ExitHandler } from 'poolifier';
8114d10e 5
268a74bb
JB
6import { WorkerAbstract } from './WorkerAbstract';
7import type { WorkerData, WorkerOptions } from './WorkerTypes';
789871d6 8import { defaultErrorHandler, defaultExitHandler, sleep } from './WorkerUtils';
a4624c96 9
268a74bb 10export class WorkerDynamicPool extends WorkerAbstract<WorkerData> {
f2bf9948 11 private readonly pool: DynamicThreadPool<WorkerData>;
a4624c96
JB
12
13 /**
14 * Create a new `WorkerDynamicPool`.
15 *
0e4fa348
JB
16 * @param workerScript -
17 * @param workerOptions -
a4624c96 18 */
4d7227e6
JB
19 constructor(workerScript: string, workerOptions?: WorkerOptions) {
20 super(workerScript, workerOptions);
0e4fa348 21 this.workerOptions.poolOptions.errorHandler = (
789871d6 22 this.workerOptions?.poolOptions?.errorHandler ?? defaultErrorHandler
0e4fa348
JB
23 ).bind(this) as ErrorHandler<Worker>;
24 this.workerOptions.poolOptions.exitHandler = (
789871d6 25 this.workerOptions?.poolOptions?.exitHandler ?? defaultExitHandler
0e4fa348
JB
26 ).bind(this) as ExitHandler<Worker>;
27 this.workerOptions.poolOptions.messageHandler.bind(this);
e7aeea18
JB
28 this.pool = new DynamicThreadPool<WorkerData>(
29 this.workerOptions.poolMinSize,
30 this.workerOptions.poolMaxSize,
31 this.workerScript,
32 this.workerOptions.poolOptions
33 );
a4624c96
JB
34 }
35
36 get size(): number {
4597fdc5 37 return this.pool.workerNodes.length;
a4624c96
JB
38 }
39
72092cfc
JB
40 get maxElementsPerWorker(): number | undefined {
41 return undefined;
a4624c96
JB
42 }
43
962a8159
JB
44 get emitter(): EventEmitterAsyncResource | undefined {
45 return this.pool?.emitter;
46 }
47
8baf3f8f 48 /** @inheritDoc */
6c3cfef8
JB
49 public async start(): Promise<void> {
50 // This is intentional
51 }
a4624c96 52
8baf3f8f 53 /** @inheritDoc */
ded13d97
JB
54 public async stop(): Promise<void> {
55 return this.pool.destroy();
56 }
57
8baf3f8f 58 /** @inheritDoc */
c3ee95af 59 public async addElement(elementData: WorkerData): Promise<void> {
a4624c96 60 await this.pool.execute(elementData);
4bfd80fa 61 // Start element sequentially to optimize memory at startup
789871d6 62 this.workerOptions.elementStartDelay > 0 && (await sleep(this.workerOptions.elementStartDelay));
a4624c96
JB
63 }
64}