chore: v2.4.0-1

[poolifier.git] / src / pools / selection-strategies / less-used-worker-choice-strategy.ts

diff --git a/src/pools/selection-strategies/less-used-worker-choice-strategy.ts b/src/pools/selection-strategies/less-used-worker-choice-strategy.ts
index 61c8fb20643319deb4f64b1e9a7054dc4ea13719..9cae4a54ae336204e4ab00f29b7789c280101682 100644 (file)
--- a/src/pools/selection-strategies/less-used-worker-choice-strategy.ts
+++ b/src/pools/selection-strategies/less-used-worker-choice-strategy.ts
@@ -19,21 +19,24 @@ export class LessUsedWorkerChoiceStrategy<
   }
 
   /** {@inheritDoc} */
-  public choose (): Worker {
+  public choose (): number {
     let minNumberOfTasks = Infinity
-    let lessUsedWorker!: Worker
-    for (const value of this.pool.workers.values()) {
-      const worker = value.worker
-      const tasksUsage = this.pool.getWorkerTasksUsage(worker)
-      const workerTasks =
-        (tasksUsage?.run as number) + (tasksUsage?.running as number)
+    let lessUsedWorkerKey!: number
+    for (const [index, workerItem] of this.pool.workers.entries()) {
+      const tasksUsage = workerItem.tasksUsage
+      const workerTasks = tasksUsage?.run + tasksUsage?.running
       if (!this.isDynamicPool && workerTasks === 0) {
-        return worker
+        return index
       } else if (workerTasks < minNumberOfTasks) {
         minNumberOfTasks = workerTasks
-        lessUsedWorker = worker
+        lessUsedWorkerKey = index
       }
     }
-    return lessUsedWorker
+    return lessUsedWorkerKey
+  }
+
+  /** {@inheritDoc} */
+  public remove (workerKey: number): boolean {
+    return true
   }
 }