perf: reduce pool info property internal usage

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

Author: jerome-benoit

deno.json

@@ -3,9 +3,7 @@
   "version": "0.5.10",
   "exports": "./src/mod.ts",
   "compilerOptions": {
-    "lib": [
-      "deno.worker"
-    ],
+    "lib": ["deno.worker"],
     "strict": true
   },
   "tasks": {
@@ -27,9 +25,7 @@
     "documentation": "deno doc ./src/mod.ts"
   },
   "test": {
-    "include": [
-      "./tests/**/*.test.mjs"
-    ]
+    "include": ["./tests/**/*.test.mjs"]
   },
   "fmt": {
     "semiColons": false,
@@ -42,18 +38,8 @@
     "@std/testing": "jsr:@std/testing@^1.0.15"
   },
   "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/abstract-pool.ts

@@ -358,18 +358,8 @@ export abstract class AbstractPool<
               : accumulator,
           0,
         ),
-        stealingWorkerNodes: this.workerNodes.reduce(
-          (accumulator, _, workerNodeKey) =>
-            this.isWorkerNodeStealing(workerNodeKey)
-              ? accumulator + 1
-              : accumulator,
-          0,
-        ),
-        queuedTasks: this.workerNodes.reduce(
-          (accumulator, workerNode) =>
-            accumulator + workerNode.usage.tasks.queued,
-          0,
-        ),
+        stealingWorkerNodes: this.getStealingWorkerNodes(),
+        queuedTasks: this.getQueuedTasks(),
         maxQueuedTasks: this.workerNodes.reduce(
           (accumulator, workerNode) =>
             accumulator + (workerNode.usage.tasks.maxQueued ?? 0),
@@ -852,6 +842,9 @@ export abstract class AbstractPool<
     message: MessageValue<Data>,
   ): Promise<boolean> {
     const targetWorkerNodeKeys = [...this.workerNodes.keys()]
+    if (targetWorkerNodeKeys.length === 0) {
+      return true
+    }
     const responsesReceived: MessageValue<Response>[] = []
     const taskFunctionOperationsListener = (
       message: MessageValue<Response>,
@@ -1002,6 +995,22 @@ export abstract class AbstractPool<
       : new Error(`Task '${taskName}' id '${taskId}' aborted`)
   }
 
+  private getQueuedTasks(): number {
+    return this.workerNodes.reduce((accumulator, workerNode) => {
+      return accumulator + workerNode.usage.tasks.queued
+    }, 0)
+  }
+
+  private getStealingWorkerNodes(): number {
+    return this.workerNodes.reduce(
+      (accumulator, _, workerNodeKey) =>
+        this.isWorkerNodeStealing(workerNodeKey)
+          ? accumulator + 1
+          : accumulator,
+      0,
+    )
+  }
+
   /**
    * Gets task function worker choice strategy, if any.
    *
@@ -1827,7 +1836,7 @@ export abstract class AbstractPool<
       !this.started ||
       this.destroying ||
       this.workerNodes.length <= 1 ||
-      this.info.queuedTasks === 0
+      this.getQueuedTasks() === 0
     )
   }
 
@@ -1976,7 +1985,7 @@ export abstract class AbstractPool<
   private readonly isStealingRatioReached = (): boolean => {
     return (
       this.opts.tasksQueueOptions?.tasksStealingRatio === 0 ||
-      (this.info.stealingWorkerNodes ?? 0) >
+      this.getStealingWorkerNodes() >
         Math.ceil(
           this.workerNodes.length *
             this.opts.tasksQueueOptions!.tasksStealingRatio!,