- if (this.getLastWorkerSetElement().numberOfWorkerElements >= this.maxElementsPerWorker) {
- this.startWorker();
- // Start worker sequentially to optimize memory at startup
- await Utils.sleep(this.workerStartDelay);
+ 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 sleep(this.workerOptions.elementStartDelay);