fix: get worker on demand

FraunhoferIOSB · Mar 3, 2024 · 53331d7 · 53331d7
1 parent 4e21e60
commit 53331d7
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/projects/aas-server/src/app/aas-provider/parallel.ts b/projects/aas-server/src/app/aas-provider/parallel.ts
@@ -83,11 +83,7 @@ export class Parallel extends EventEmitter {
     ) {
         super();
         this.script = path.resolve(this.variable.CONTENT_ROOT, 'aas-scan-worker.js');
-        if (fs.existsSync(this.script)) {
-            for (let i = 0; i < this.variable.MAX_WORKERS; i++) {
-                this.pool.set(new Worker(this.script, { env: SHARE_ENV }), true);
-            }
-        } else {
+        if (!fs.existsSync(this.script)) {
             this.logger.error(`${this.script} does not exist.`);
         }
     }
@@ -118,6 +114,12 @@ export class Parallel extends EventEmitter {
             }
         }
 
+        if (this.pool.size < this.variable.MAX_WORKERS) {
+            const worker = new Worker(this.script, { env: SHARE_ENV });
+            this.pool.set(worker, true);
+            return worker;
+        }
+
         return undefined;
     }