X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=dd12fdb5a59ee1f118a5a6b2016451d2ea1f735b;hb=2541c612bf17b3c2dd3b7cf3c9663c546bd84aaf;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..dd12fdb5 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,43 +1,44 @@ -import { WorkerData, WorkerEvents, WorkerSetElement } from '../types/Worker'; +import { WorkerEvents, 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'; -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 {number} workerStartDelay */ - constructor(workerScript: string, maxElementsPerWorker = 1) { - super(workerScript); - this.workers = new Set(); + constructor(workerScript: string, maxElementsPerWorker = 1, workerStartDelay?: number) { + super(workerScript, workerStartDelay); + this.workerSet = new Set(); this.maxElementsPerWorker = maxElementsPerWorker; } get size(): number { - return this.workers.size; + return this.workerSet.size; } /** * - * @return {Promise} + * @param elementData + * @returns {Promise} * @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 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.getLastWorkerSetElement().numberOfWorkerElements++; @@ -45,42 +46,62 @@ export default class WorkerSet extends Wrk { /** * - * @return {Promise} + * @returns {Promise} * @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 {Promise} + * @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', () => { }); + worker.on('error', () => { }); + worker.on('exit', (code) => { + if (code !== 0) { + console.error(`Worker stopped with exit code ${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) { } return workerSetElement; } private getLastWorker(): Worker { return this.getLastWorkerSetElement().worker; } + + private getWorkerSetElementByWorker(worker: Worker): WorkerSetElement { + let workerSetElt: WorkerSetElement; + this.workerSet.forEach((workerSetElement) => { + if (workerSetElement.worker.threadId === worker.threadId) { + workerSetElt = workerSetElement; + } + }); + return workerSetElt; + } }