X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=c1fecdcec2f7f6b03adfe412a2bfe18c8d997935;hb=b3d7d65476a4ab586b3ccd188f0bfbe8452aba0e;hp=42109a98567609739d70a4e00c3c10d6e7420d07;hpb=b3ded6aeb2468b6fa4fa7f456da929912626d8ec;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index 42109a98..c1fecdce 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -3,10 +3,8 @@ import { EventEmitter } from 'node:events'; import { SHARE_ENV, Worker } from 'node:worker_threads'; -import type { ThreadPoolOptions } from 'poolifier'; - import { WorkerAbstract } from './WorkerAbstract'; -import { WorkerConstants } from './WorkerConstants'; +import { DEFAULT_POOL_OPTIONS, EMPTY_FUNCTION, workerSetVersion } from './WorkerConstants'; import { type SetInfo, type WorkerData, @@ -18,11 +16,6 @@ import { } from './WorkerTypes'; import { sleep } from './WorkerUtils'; -const DEFAULT_POOL_OPTIONS: ThreadPoolOptions = { - enableEvents: true, - restartWorkerOnError: true, -}; - export class WorkerSet extends WorkerAbstract { public readonly emitter!: EventEmitter; private readonly workerSet: Set; @@ -35,6 +28,18 @@ export class WorkerSet extends WorkerAbstract { */ constructor(workerScript: string, workerOptions: WorkerOptions) { super(workerScript, workerOptions); + if ( + this.workerOptions.elementsPerWorker === null || + this.workerOptions.elementsPerWorker === undefined + ) { + throw new TypeError('Elements per worker is not defined'); + } + if (!Number.isSafeInteger(this.workerOptions.elementsPerWorker)) { + throw new TypeError('Elements per worker must be an integer'); + } + if (this.workerOptions.elementsPerWorker <= 0) { + throw new RangeError('Elements per worker must be greater than zero'); + } this.workerOptions.poolOptions = { ...DEFAULT_POOL_OPTIONS, ...this.workerOptions.poolOptions, @@ -47,7 +52,7 @@ export class WorkerSet extends WorkerAbstract { get info(): SetInfo { return { - version: WorkerConstants.version, + version: workerSetVersion, type: 'set', worker: 'thread', size: this.size, @@ -78,13 +83,13 @@ export class WorkerSet extends WorkerAbstract { public async stop(): Promise { for (const workerSetElement of this.workerSet) { const worker = workerSetElement.worker; - const workerExitPromise = new Promise((resolve) => { + const waitWorkerExit = new Promise((resolve) => { worker.on('exit', () => { resolve(); }); }); await worker.terminate(); - await workerExitPromise; + await waitWorkerExit; } } @@ -113,10 +118,7 @@ export class WorkerSet extends WorkerAbstract { env: SHARE_ENV, ...this.workerOptions.poolOptions?.workerOptions, }); - worker.on( - 'message', - this.workerOptions.poolOptions?.messageHandler ?? WorkerConstants.EMPTY_FUNCTION, - ); + worker.on('message', this.workerOptions.poolOptions?.messageHandler ?? EMPTY_FUNCTION); worker.on('message', (message: WorkerMessage) => { if (message.event === WorkerMessageEvents.startedWorkerElement) { this.emitter?.emit(WorkerSetEvents.elementStarted, this.info); @@ -124,24 +126,15 @@ export class WorkerSet extends WorkerAbstract { this.emitter?.emit(WorkerSetEvents.elementError, message.data); } }); - worker.on( - 'error', - this.workerOptions.poolOptions?.errorHandler ?? WorkerConstants.EMPTY_FUNCTION, - ); + worker.on('error', this.workerOptions.poolOptions?.errorHandler ?? EMPTY_FUNCTION); worker.on('error', (error) => { this.emitter?.emit(WorkerSetEvents.error, error); if (this.workerOptions.poolOptions?.restartWorkerOnError) { this.addWorkerSetElement(); } }); - worker.on( - 'online', - this.workerOptions.poolOptions?.onlineHandler ?? WorkerConstants.EMPTY_FUNCTION, - ); - worker.on( - 'exit', - this.workerOptions.poolOptions?.exitHandler ?? WorkerConstants.EMPTY_FUNCTION, - ); + worker.on('online', this.workerOptions.poolOptions?.onlineHandler ?? EMPTY_FUNCTION); + worker.on('exit', this.workerOptions.poolOptions?.exitHandler ?? EMPTY_FUNCTION); worker.once('exit', () => this.removeWorkerSetElement(this.getWorkerSetElementByWorker(worker)!), );