X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=b62f63df546d3709e3c00bb4836131501b0076f2;hb=36367c31509f7b23c5788ecf6c84ad9be3734c73;hp=83e60df06f623e6ceaa0fb0ca1dedaa2c05b1a4d;hpb=4d7227e61934a6b082a4d89268c454f7ee3605e1;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index 83e60df0..b62f63df 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -19,8 +19,8 @@ export default class WorkerSet extends WorkerAbstract { */ constructor(workerScript: string, workerOptions?: WorkerOptions) { super(workerScript, workerOptions); - this.messageHandler = workerOptions?.messageHandler ?? (() => { /* This is intentional */ }); this.workerSet = new Set(); + this.messageHandler = workerOptions?.messageHandler ?? (() => { /* This is intentional */ }); } get size(): number { @@ -44,9 +44,8 @@ export default class WorkerSet extends WorkerAbstract { 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++; - this.workerOptions.elementStartDelay > 0 && await Utils.sleep(this.workerOptions.elementStartDelay); } /**