X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=b62f63df546d3709e3c00bb4836131501b0076f2;hb=36367c31509f7b23c5788ecf6c84ad9be3734c73;hp=d179608ddb829877802538236f0153424a86a1d7;hpb=f2bf9948496c724976a2e05d2f20cb17700373ec;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index d179608d..b62f63df 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,52 +1,50 @@ // Partial Copyright Jerome Benoit. 2021. All Rights Reserved. -import { WorkerMessageEvents, WorkerOptions, WorkerSetElement } from '../types/Worker'; +import { WorkerData, WorkerMessageEvents, WorkerOptions, WorkerSetElement } from '../types/Worker'; import Utils from '../utils/Utils'; import { Worker } from 'worker_threads'; import WorkerAbstract from './WorkerAbstract'; import { WorkerUtils } from './WorkerUtils'; -export default class WorkerSet extends WorkerAbstract { - public readonly maxElementsPerWorker: number; - private readonly messageHandler: (message: unknown) => void | Promise; +export default class WorkerSet extends WorkerAbstract { private readonly workerSet: Set; + private readonly messageHandler: (message: unknown) => void | Promise; /** * Create a new `WorkerSet`. * * @param workerScript - * @param maxElementsPerWorker - * @param workerStartDelay - * @param opts + * @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(); + this.messageHandler = workerOptions?.messageHandler ?? (() => { /* This is intentional */ }); } get size(): number { return this.workerSet.size; } + get maxElementsPerWorker(): number | null { + return this.workerOptions.elementsPerWorker; + } + /** * * @param elementData * @returns * @public */ - public async addElement(elementData: T): Promise { + public async addElement(elementData: WorkerData): Promise { if (!this.workerSet) { 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.getLastWorkerSetElement().numberOfWorkerElements >= this.workerOptions.elementsPerWorker) { + await this.startWorker(); } - this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, data: elementData }); + this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, workerOptions: this.workerOptions, data: elementData }); this.getLastWorkerSetElement().numberOfWorkerElements++; } @@ -56,9 +54,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(); } /** @@ -77,7 +73,7 @@ export default class WorkerSet extends WorkerAbstract { * * @private */ - private startWorker(): void { + private async startWorker(): Promise { const worker = new Worker(this.workerScript); worker.on('message', (msg) => { (async () => { @@ -90,6 +86,8 @@ export default class WorkerSet extends WorkerAbstract { 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 Utils.sleep(this.workerOptions.workerStartDelay); } private getLastWorkerSetElement(): WorkerSetElement {