From: Jérôme Benoit <jerome.benoit@sap.com>
Date: Fri, 21 Jul 2023 16:03:25 +0000 (+0200)
Subject: fix: ensure task concurrency is enforced
X-Git-Tag: v2.6.20~6
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=b5e113f6151d0647d6ec9b3be9c000e83db9065e;p=poolifier.git

fix: ensure task concurrency is enforced

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

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index 0d3d2183..dde31ea4 100644
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -648,8 +648,7 @@ export abstract class AbstractPool<
         this.opts.enableTasksQueue === true &&
         (this.busy ||
           this.workerNodes[workerNodeKey].usage.tasks.executing >=
-            ((this.opts.tasksQueueOptions as TasksQueueOptions)
-              .concurrency as number))
+            (this.opts.tasksQueueOptions?.concurrency as number))
       ) {
         this.enqueueTask(workerNodeKey, task)
       } else {
@@ -936,14 +935,14 @@ export abstract class AbstractPool<
       }
     })
     const workerInfo = this.getWorkerInfo(workerNodeKey)
-    workerInfo.dynamic = true
-    if (this.workerChoiceStrategyContext.getStrategyPolicy().useDynamicWorker) {
-      workerInfo.ready = true
-    }
     this.sendToWorker(workerNodeKey, {
       checkActive: true,
       workerId: workerInfo.id as number
     })
+    workerInfo.dynamic = true
+    if (this.workerChoiceStrategyContext.getStrategyPolicy().useDynamicWorker) {
+      workerInfo.ready = true
+    }
     return workerNodeKey
   }
 
@@ -1085,7 +1084,9 @@ export abstract class AbstractPool<
       this.promiseResponseMap.delete(message.id as string)
       if (
         this.opts.enableTasksQueue === true &&
-        this.tasksQueueSize(workerNodeKey) > 0
+        this.tasksQueueSize(workerNodeKey) > 0 &&
+        this.workerNodes[workerNodeKey].usage.tasks.executing <
+          (this.opts.tasksQueueOptions?.concurrency as number)
       ) {
         this.executeTask(
           workerNodeKey,
diff --git a/src/worker/abstract-worker.ts b/src/worker/abstract-worker.ts
index 0f0e0a39..428f6313 100644
--- a/src/worker/abstract-worker.ts
+++ b/src/worker/abstract-worker.ts
@@ -335,7 +335,6 @@ export abstract class AbstractWorker<
       this.checkActive.bind(this),
       (this.opts.maxInactiveTime ?? DEFAULT_MAX_INACTIVE_TIME) / 2
     )
-    this.activeInterval.unref()
   }
 
   /**