feat: check worker inactive time only on dynamic worker

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

diff --git a/CHANGELOG.md b/CHANGELOG.md
index df3eeb3046e72fb53ea62b528fe454ce1a3eb7a1..1863751c248ab9b9149ccc203ae4d028773d2ef9 100644 (file)
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -15,6 +15,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - Add minimum and maximum to internal measurement statistics.
 - Add `runTime` and `waitTime` to pool information.
+- Check worker inactive time only on dynamic worker.
 
 ## [2.6.8] - 2023-07-03
 

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index 730c0dd226c087cb46d6b2f68eb6288ec6885c8f..4b1a05ff63f7a9b78ecc66c8541b272cad18a61b 100644 (file)
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -962,6 +962,7 @@ export abstract class AbstractPool<
         void (this.destroyWorker(worker) as Promise<void>)
       }
     })
+    this.sendToWorker(worker, { dynamic: true })
     return worker
   }
 

diff --git a/src/utility-types.ts b/src/utility-types.ts
index 9ecf56577f999f4d56a5474917d522f644993749..980c00896a0ebf23f75162605cccf52548cc535f 100644 (file)
--- a/src/utility-types.ts
+++ b/src/utility-types.ts
@@ -85,6 +85,10 @@ export interface MessageValue<Data = unknown, ErrorData = unknown>
    * Whether the worker has started or not.
    */
   readonly started?: boolean
+  /**
+   * Whether the worker is dynamic or not.
+   */
+  readonly dynamic?: boolean
 }
 
 /**

diff --git a/src/worker/abstract-worker.ts b/src/worker/abstract-worker.ts
index 7d81a88ccc816803bcdcdae4f89cb9dd56486f51..b8b442ecd2c0e2521a2c82b899620aa22197fbd7 100644 (file)
--- a/src/worker/abstract-worker.ts
+++ b/src/worker/abstract-worker.ts
@@ -55,7 +55,7 @@ export abstract class AbstractWorker<
   /**
    * Handler id of the `aliveInterval` worker alive check.
    */
-  protected readonly aliveInterval?: NodeJS.Timeout
+  protected aliveInterval?: NodeJS.Timeout
   /**
    * Constructs a new poolifier worker.
    *
@@ -88,12 +88,6 @@ export abstract class AbstractWorker<
     this.checkWorkerOptions(this.opts)
     this.checkTaskFunctions(taskFunctions)
     if (!this.isMain) {
-      this.lastTaskTimestamp = performance.now()
-      this.aliveInterval = setInterval(
-        this.checkAlive.bind(this),
-        (this.opts.maxInactiveTime ?? DEFAULT_MAX_INACTIVE_TIME) / 2
-      )
-      this.checkAlive.bind(this)()
       this.mainWorker?.on('message', this.messageListener.bind(this))
     }
   }
@@ -151,7 +145,13 @@ export abstract class AbstractWorker<
    * @param message - Message received.
    */
   protected messageListener (message: MessageValue<Data, Data>): void {
-    if (message.id != null && message.data != null) {
+    if (message.dynamic === true) {
+      // Worker dynamic message received
+      this.startCheckAlive()
+    } else if (message.statistics != null) {
+      // Statistics message received
+      this.statistics = message.statistics
+    } else if (message.id != null && message.data != null) {
       // Task message received
       const fn = this.getTaskFunction(message.name)
       if (isAsyncFunction(fn)) {
@@ -159,9 +159,6 @@ export abstract class AbstractWorker<
       } else {
         this.runInAsyncScope(this.runSync.bind(this), this, fn, message)
       }
-    } else if (message.statistics != null) {
-      // Statistics message received
-      this.statistics = message.statistics
     } else if (message.kill != null) {
       // Kill message received
       this.aliveInterval != null && clearInterval(this.aliveInterval)
@@ -169,6 +166,15 @@ export abstract class AbstractWorker<
     }
   }
 
+  private startCheckAlive (): void {
+    this.lastTaskTimestamp = performance.now()
+    this.aliveInterval = setInterval(
+      this.checkAlive.bind(this),
+      (this.opts.maxInactiveTime ?? DEFAULT_MAX_INACTIVE_TIME) / 2
+    )
+    this.checkAlive.bind(this)()
+  }
+
   /**
    * Returns the main worker.
    *
@@ -243,7 +249,9 @@ export abstract class AbstractWorker<
         id: message.id
       })
     } finally {
-      !this.isMain && (this.lastTaskTimestamp = performance.now())
+      if (!this.isMain && this.aliveInterval != null) {
+        this.lastTaskTimestamp = performance.now()
+      }
     }
   }
 
@@ -281,7 +289,9 @@ export abstract class AbstractWorker<
         })
       })
       .finally(() => {
-        !this.isMain && (this.lastTaskTimestamp = performance.now())
+        if (!this.isMain && this.aliveInterval != null) {
+          this.lastTaskTimestamp = performance.now()
+        }
       })
       .catch(EMPTY_FUNCTION)
   }