build(deps): apply updates
[e-mobility-charging-stations-simulator.git] / src / worker / WorkerStaticPool.ts
CommitLineData
962a8159 1import type EventEmitterAsyncResource from 'node:events';
01f4001e 2import type { Worker } from 'node:worker_threads';
0e4fa348
JB
3
4import { type ErrorHandler, type ExitHandler, FixedThreadPool } 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 WorkerStaticPool extends WorkerAbstract<WorkerData> {
f2bf9948 11 private readonly pool: FixedThreadPool<WorkerData>;
a4624c96
JB
12
13 /**
14 * Create a new `WorkerStaticPool`.
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 FixedThreadPool(
29 this.workerOptions.poolMaxSize,
30 this.workerScript,
31 this.workerOptions.poolOptions
32 );
a4624c96
JB
33 }
34
35 get size(): number {
4597fdc5 36 return this.pool.workerNodes.length;
a4624c96
JB
37 }
38
72092cfc
JB
39 get maxElementsPerWorker(): number | undefined {
40 return undefined;
a4624c96
JB
41 }
42
962a8159
JB
43 get emitter(): EventEmitterAsyncResource | undefined {
44 return this.pool?.emitter;
45 }
46
8baf3f8f 47 /** @inheritDoc */
81797102
JB
48 public async start(): Promise<void> {
49 // This is intentional
50 }
a4624c96 51
8baf3f8f 52 /** @inheritDoc */
ded13d97
JB
53 public async stop(): Promise<void> {
54 return this.pool.destroy();
55 }
56
8baf3f8f 57 /** @inheritDoc */
c3ee95af 58 public async addElement(elementData: WorkerData): Promise<void> {
a4624c96 59 await this.pool.execute(elementData);
4bfd80fa 60 // Start element sequentially to optimize memory at startup
789871d6 61 this.workerOptions.elementStartDelay > 0 && (await sleep(this.workerOptions.elementStartDelay));
a4624c96
JB
62 }
63}