X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=eaa19ac8f384ed5ce591362696e13bfdf765ab5a;hb=aaf2bf9c2ec7712394d7ab9da12449262d894e60;hp=5477ab0d744c2d783fe416ea55e4e0f1b0fdffc9;hpb=4581acf33b078cca4a2a3e77c774788149dca5e7;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index 5477ab0d..eaa19ac8 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,29 +1,29 @@ -// Partial Copyright Jerome Benoit. 2021. All Rights Reserved. +// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. -import { WorkerData, WorkerMessageEvents, WorkerOptions, WorkerSetElement, WorkerStartOptions } from '../types/Worker'; +import { Worker } from 'node:worker_threads'; -import Utils from '../utils/Utils'; -import { Worker } from 'worker_threads'; -import WorkerAbstract from './WorkerAbstract'; +import { WorkerAbstract } from './WorkerAbstract'; +import { WorkerConstants } from './WorkerConstants'; +import { + type MessageHandler, + type WorkerData, + WorkerMessageEvents, + type WorkerOptions, + type WorkerSetElement, +} from './WorkerTypes'; import { WorkerUtils } from './WorkerUtils'; -export default class WorkerSet extends WorkerAbstract { - public readonly maxElementsPerWorker: number; - private readonly messageHandler: (message: unknown) => void | Promise; +export class WorkerSet extends WorkerAbstract { private readonly workerSet: Set; /** * Create a new `WorkerSet`. * - * @param workerScript - * @param maxElementsPerWorker - * @param workerStartOptions - * @param opts + * @param workerScript - + * @param workerOptions - */ - constructor(workerScript: string, maxElementsPerWorker = 1, workerStartOptions?: WorkerStartOptions, opts?: WorkerOptions) { - super(workerScript, workerStartOptions); - this.maxElementsPerWorker = maxElementsPerWorker; - this.messageHandler = opts?.messageHandler ?? (() => { /* This is intentional */ }); + constructor(workerScript: string, workerOptions?: WorkerOptions) { + super(workerScript, workerOptions); this.workerSet = new Set(); } @@ -31,22 +31,35 @@ export default class WorkerSet extends WorkerAbstract { return this.workerSet.size; } + get maxElementsPerWorker(): number | undefined { + return this.workerOptions.elementsPerWorker; + } + /** * - * @param elementData + * @param elementData - * @returns * @public */ public async addElement(elementData: WorkerData): Promise { if (!this.workerSet) { - throw new Error('Cannot add a WorkerSet element: workers\' set does not exist'); + throw new Error("Cannot add a WorkerSet element: workers' set does not exist"); } - if (this.getLastWorkerSetElement().numberOfWorkerElements >= this.maxElementsPerWorker) { + if ( + this.workerSet.size === 0 || + this.getLastWorkerSetElement().numberOfWorkerElements >= this.workerOptions.elementsPerWorker + ) { await this.startWorker(); } - this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, data: elementData }); + this.getLastWorker().postMessage({ + id: WorkerMessageEvents.startWorkerElement, + data: elementData, + }); this.getLastWorkerSetElement().numberOfWorkerElements++; - this.elementStartDelay > 0 && await Utils.sleep(this.elementStartDelay); + // Start element sequentially to optimize memory at startup + if (this.workerOptions.elementStartDelay > 0) { + await WorkerUtils.sleep(this.workerOptions.elementStartDelay); + } } /** @@ -71,29 +84,32 @@ export default class WorkerSet extends WorkerAbstract { } /** - * - * @private + * Start a new `Worker`. */ private async startWorker(): Promise { const worker = new Worker(this.workerScript); - worker.on('message', (msg) => { - (async () => { - await this.messageHandler(msg); - })().catch(() => { /* This is intentional */ }); - }); - worker.on('error', () => { /* This is intentional */ }); + worker.on( + 'message', + (this.workerOptions?.messageHandler ?? WorkerConstants.EMPTY_FUNCTION).bind( + this + ) as MessageHandler + ); + worker.on('error', WorkerUtils.defaultErrorHandler.bind(this) as (err: Error) => void); worker.on('exit', (code) => { WorkerUtils.defaultExitHandler(code); this.workerSet.delete(this.getWorkerSetElementByWorker(worker)); }); this.workerSet.add({ worker, numberOfWorkerElements: 0 }); // Start worker sequentially to optimize memory at startup - this.workerStartDelay > 0 && await Utils.sleep(this.workerStartDelay); + this.workerOptions.workerStartDelay > 0 && + (await WorkerUtils.sleep(this.workerOptions.workerStartDelay)); } private getLastWorkerSetElement(): WorkerSetElement { let workerSetElement: WorkerSetElement; - for (workerSetElement of this.workerSet) { /* This is intentional */ } + for (workerSetElement of this.workerSet) { + /* This is intentional */ + } return workerSetElement; }