X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=9b9ad3324540ce37dcbb828f42420535f668acf6;hb=2a370053f45f2d58e90ab7b292294c521a262ca1;hp=50d099d856633ff5cbc8ad6c5d1f57813a750b1e;hpb=c045d9a97ebdf3747b82746b733b0c60a7db3f32;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index 50d099d8..9b9ad332 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,86 +1,110 @@ -import { WorkerData, WorkerEvents, WorkerSetElement } from '../types/Worker'; +// Partial Copyright Jerome Benoit. 2021. All Rights Reserved. + +import { WorkerMessageEvents, WorkerSetElement } from '../types/Worker'; -import Constants from '../utils/Constants'; import Utils from '../utils/Utils'; import { Worker } from 'worker_threads'; -import Wrk from './Wrk'; +import WorkerAbstract from './WorkerAbstract'; +import { WorkerUtils } from './WorkerUtils'; -export default class WorkerSet extends Wrk { +export default class WorkerSet extends WorkerAbstract { public maxElementsPerWorker: number; - private workers: Set; + private workerSet: Set; /** * Create a new `WorkerSet`. * - * @param {string} workerScript - * @param {number} maxElementsPerWorker + * @param workerScript + * @param maxElementsPerWorker + * @param workerStartDelay + * @param messageListenerCallback */ - constructor(workerScript: string, maxElementsPerWorker = 1) { - super(workerScript); - this.workers = new Set(); + constructor(workerScript: string, maxElementsPerWorker = 1, workerStartDelay?: number, messageListenerCallback: (message: any) => void = () => { /* This is intentional */ }) { + super(workerScript, workerStartDelay, messageListenerCallback); + this.workerSet = new Set(); this.maxElementsPerWorker = maxElementsPerWorker; } get size(): number { - return this.workers.size; + return this.workerSet.size; } /** * - * @return {Promise} + * @param elementData + * @returns * @public */ - public async addElement(elementData: WorkerData): Promise { - if (!this.workers) { - throw Error('Cannot add a WorkerSet element: workers set does not exist'); + public async addElement(elementData: T): Promise { + if (!this.workerSet) { + throw new Error('Cannot add a WorkerSet element: workers\' set does not exist'); } if (this.getLastWorkerSetElement().numberOfWorkerElements >= this.maxElementsPerWorker) { - void this.startWorker(); + this.startWorker(); // Start worker sequentially to optimize memory at startup - void Utils.sleep(Constants.START_WORKER_DELAY); + await Utils.sleep(this.workerStartDelay); } - this.getLastWorker().postMessage({ id: WorkerEvents.START_WORKER_ELEMENT, workerData: elementData }); + this.getLastWorker().postMessage({ id: WorkerMessageEvents.START_WORKER_ELEMENT, data: elementData }); this.getLastWorkerSetElement().numberOfWorkerElements++; } /** * - * @return {Promise} + * @returns * @public */ public async start(): Promise { - await this.startWorker(); + this.startWorker(); // Start worker sequentially to optimize memory at startup - await Utils.sleep(Constants.START_WORKER_DELAY); + await Utils.sleep(this.workerStartDelay); + } + + /** + * + * @returns + * @public + */ + public async stop(): Promise { + for (const workerSetElement of this.workerSet) { + await workerSetElement.worker.terminate(); + } + this.workerSet.clear(); } /** * - * @return {Promise} * @private */ - private async startWorker() { - return new Promise((resolve, reject) => { - const worker = new Worker(this.workerScript); - worker.on('message', resolve); - worker.on('error', reject); - worker.on('exit', (code) => { - if (code !== 0) { - reject(new Error(`Worker stopped with exit code ${code}`)); - } - }); - this.workers.add({ worker, numberOfWorkerElements: 0 }); + private startWorker(): void { + const worker = new Worker(this.workerScript); + worker.on('message', this.messageListener); + worker.on('error', () => { /* This is intentional */ }); + worker.on('exit', (code) => { + WorkerUtils.defaultExitHandler(code); + this.workerSet.delete(this.getWorkerSetElementByWorker(worker)); }); + this.workerSet.add({ worker, numberOfWorkerElements: 0 }); } private getLastWorkerSetElement(): WorkerSetElement { let workerSetElement: WorkerSetElement; // eslint-disable-next-line no-empty - for (workerSetElement of this.workers) { } + for (workerSetElement of this.workerSet) { /* This is intentional */ } return workerSetElement; } private getLastWorker(): Worker { return this.getLastWorkerSetElement().worker; } + + private getWorkerSetElementByWorker(worker: Worker): WorkerSetElement { + let workerSetElt: WorkerSetElement; + for (const workerSetElement of this.workerSet) { + if (workerSetElement.worker.threadId === worker.threadId) { + workerSetElt = workerSetElement; + break; + } + } + return workerSetElt; + } }