X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=eaa19ac8f384ed5ce591362696e13bfdf765ab5a;hb=aaf2bf9c2ec7712394d7ab9da12449262d894e60;hp=64399c87616b11b488d63a60e45620eca7cb2d3b;hpb=c3ee95af4edd541595e3873c8aa4c93d38e59474;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index 64399c87..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 } 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 workerStartDelay - * @param opts + * @param workerScript - + * @param workerOptions - */ - constructor(workerScript: string, maxElementsPerWorker = 1, workerStartDelay?: number, opts?: WorkerOptions) { - super(workerScript, workerStartDelay); - this.maxElementsPerWorker = maxElementsPerWorker; - this.messageHandler = opts?.messageHandler ?? (() => { /* This is intentional */ }); + constructor(workerScript: string, workerOptions?: WorkerOptions) { + super(workerScript, workerOptions); this.workerSet = new Set(); } @@ -31,23 +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) { - this.startWorker(); - // Start worker sequentially to optimize memory at startup - await Utils.sleep(this.workerStartDelay); + 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++; + // Start element sequentially to optimize memory at startup + if (this.workerOptions.elementStartDelay > 0) { + await WorkerUtils.sleep(this.workerOptions.elementStartDelay); + } } /** @@ -56,9 +68,7 @@ export default class WorkerSet extends WorkerAbstract { * @public */ public async start(): Promise { - this.startWorker(); - // Start worker sequentially to optimize memory at startup - await Utils.sleep(this.workerStartDelay); + await this.startWorker(); } /** @@ -74,27 +84,32 @@ export default class WorkerSet extends WorkerAbstract { } /** - * - * @private + * Start a new `Worker`. */ - private startWorker(): void { + 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.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; }