fix: fix worker usage statistics computation

Signed-off-by: Jérôme Benoit <[email protected]>

Author: jerome-benoit

deno.json

@@ -3,9 +3,7 @@
   "version": "0.5.1",
   "exports": "./src/mod.ts",
   "compilerOptions": {
-    "lib": [
-      "deno.worker"
-    ],
+    "lib": ["deno.worker"],
     "strict": true
   },
   "tasks": {
@@ -26,9 +24,7 @@
     "documentation": "deno doc ./src/mod.ts"
   },
   "test": {
-    "include": [
-      "./tests/**/*.test.mjs"
-    ]
+    "include": ["./tests/**/*.test.mjs"]
   },
   "fmt": {
     "semiColons": false,
@@ -41,18 +37,8 @@
     "@std/testing": "jsr:@std/testing@^1.0.14"
   },
   "publish": {
-    "include": [
-      "LICENSE",
-      "README.md",
-      "deno.json",
-      "src/**/*.ts"
-    ]
+    "include": ["LICENSE", "README.md", "deno.json", "src/**/*.ts"]
   },
   "lock": false,
-  "exclude": [
-    "./coverage",
-    "./dist/browser",
-    "./dist/esm",
-    "./npm"
-  ]
+  "exclude": ["./coverage", "./dist/browser", "./dist/esm", "./npm"]
 }

src/pools/selection-strategies/fair-share-worker-choice-strategy.ts

@@ -81,8 +81,9 @@ export class FairShareWorkerChoiceStrategy<
       this.pool.workerNodes[workerNodeKey]?.strategyData
         ?.virtualTaskEndTimestamp != null
     ) {
-      this.pool.workerNodes[workerNodeKey].strategyData
-        .virtualTaskEndTimestamp = undefined
+      this.pool.workerNodes[
+        workerNodeKey
+      ].strategyData.virtualTaskEndTimestamp = undefined
     }
     return true
   }

src/pools/utils.ts

@@ -1,3 +1,4 @@
+import worker from '../../examples/deno/typescript/worker.ts'
 import type { MessageValue, Task } from '../utility-types.ts'
 import {
   average,
@@ -277,14 +278,14 @@ const updateMeasurementStatistics = (
           measurementStatistics.history.toArray(),
         )
       } else if (measurementStatistics.average != null) {
-        delete measurementStatistics.average
+        measurementStatistics.average = undefined
       }
       if (measurementRequirements.median) {
         measurementStatistics.median = median(
           measurementStatistics.history.toArray(),
         )
       } else if (measurementStatistics.median != null) {
-        delete measurementStatistics.median
+        measurementStatistics.median = undefined
       }
     }
   }
@@ -380,13 +381,11 @@ export const updateEluWorkerUsage = <
   )
   if (eluTaskStatisticsRequirements?.aggregate === true) {
     if (message.taskPerformance?.elu != null) {
-      if (workerUsage.elu.utilization != null) {
-        workerUsage.elu.utilization = (workerUsage.elu.utilization +
+      workerUsage.elu.count = (workerUsage.elu.count ?? 0) + 1
+      workerUsage.elu.utilization =
+        ((workerUsage.elu.utilization ?? 0) * (workerUsage.elu.count - 1) +
           message.taskPerformance.elu.utilization) /
-          2
-      } else {
-        workerUsage.elu.utilization = message.taskPerformance.elu.utilization
-      }
+        workerUsage.elu.count
     }
   }
 }

src/pools/worker.ts

@@ -66,8 +66,9 @@ export interface MeasurementStatistics {
  * @internal
  */
 export interface EventLoopUtilizationMeasurementStatistics {
-  readonly idle: MeasurementStatistics
   readonly active: MeasurementStatistics
+  count?: number
+  readonly idle: MeasurementStatistics
   utilization?: number
 }