Add tunable for charging station start delay for linear ramp up

[e-mobility-charging-stations-simulator.git] / src / worker / WorkerStaticPool.ts

diff --git a/src/worker/WorkerStaticPool.ts b/src/worker/WorkerStaticPool.ts
index 1cbd18e8b9b1cf89094350c71ac2b1488d2d0aac..cbf46298d67022aeef3a8e35969a4643ed01ce73 100644 (file)
--- a/src/worker/WorkerStaticPool.ts
+++ b/src/worker/WorkerStaticPool.ts
@@ -1,9 +1,9 @@
 import { FixedThreadPool, PoolOptions } from 'poolifier';
+import { WorkerData, WorkerStartOptions } from '../types/Worker';
 
 import Utils from '../utils/Utils';
 import { Worker } from 'worker_threads';
 import WorkerAbstract from './WorkerAbstract';
-import { WorkerData } from '../types/Worker';
 import { WorkerUtils } from './WorkerUtils';
 
 export default class WorkerStaticPool extends WorkerAbstract<WorkerData> {
@@ -14,11 +14,11 @@ export default class WorkerStaticPool extends WorkerAbstract<WorkerData> {
    *
    * @param workerScript
    * @param numberOfThreads
-   * @param startWorkerDelay
+   * @param workerStartOptions
    * @param opts
    */
-  constructor(workerScript: string, numberOfThreads: number, startWorkerDelay?: number, opts?: PoolOptions<Worker>) {
-    super(workerScript, startWorkerDelay);
+  constructor(workerScript: string, numberOfThreads: number, workerStartOptions?: WorkerStartOptions, opts?: PoolOptions<Worker>) {
+    super(workerScript, workerStartOptions);
     opts.exitHandler = opts?.exitHandler ?? WorkerUtils.defaultExitHandler;
     this.pool = new FixedThreadPool(numberOfThreads, this.workerScript, opts);
   }
@@ -57,7 +57,7 @@ export default class WorkerStaticPool extends WorkerAbstract<WorkerData> {
    */
   public async addElement(elementData: WorkerData): Promise<void> {
     await this.pool.execute(elementData);
-    // Start worker sequentially to optimize memory at startup
-    await Utils.sleep(this.workerStartDelay);
+    // Start element sequentially to optimize memory at startup
+    this.elementStartDelay > 0 && await Utils.sleep(this.elementStartDelay);
   }
 }