refactor: cleanup worker set code

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>

diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts
index b16b95424ec7d8eca5996e7b05ddf4759ef2df13..681609585de1d388fe59135fb778fcf39fccc384 100644 (file)
--- a/src/worker/WorkerSet.ts
+++ b/src/worker/WorkerSet.ts
@@ -50,6 +50,21 @@ export class WorkerSet extends WorkerAbstract<WorkerData> {
     return this.workerOptions.elementsPerWorker;
   }
 
+  /** @inheritDoc */
+  public async start(): Promise<void> {
+    this.addWorkerSetElement();
+    // Add worker set element sequentially to optimize memory at startup
+    this.workerOptions.workerStartDelay > 0 && (await sleep(this.workerOptions.workerStartDelay));
+  }
+
+  /** @inheritDoc */
+  public async stop(): Promise<void> {
+    for (const workerSetElement of this.workerSet) {
+      await workerSetElement.worker.terminate();
+    }
+    this.workerSet.clear();
+  }
+
   /** @inheritDoc */
   public async addElement(elementData: WorkerData): Promise<void> {
     if (!this.workerSet) {
@@ -67,21 +82,6 @@ export class WorkerSet extends WorkerAbstract<WorkerData> {
     }
   }
 
-  /** @inheritDoc */
-  public async start(): Promise<void> {
-    this.addWorkerSetElement();
-    // Add worker set element sequentially to optimize memory at startup
-    this.workerOptions.workerStartDelay > 0 && (await sleep(this.workerOptions.workerStartDelay));
-  }
-
-  /** @inheritDoc */
-  public async stop(): Promise<void> {
-    for (const workerSetElement of this.workerSet) {
-      await workerSetElement.worker.terminate();
-    }
-    this.workerSet.clear();
-  }
-
   /**
    * Add a new `WorkerSetElement`.
    */