priorityQueue: Prevent same tick setImmediate (#1727)

Co-authored-by: Paul Karimov <pkarimov@microsoft.com>
caolan · Oct 17, 2020 · b0bc571 · b0bc571
1 parent aff1716
commit b0bc571
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/lib/priorityQueue.js b/lib/priorityQueue.js
@@ -28,6 +28,7 @@ import Heap from './internal/Heap';
 export default function(worker, concurrency) {
     // Start with a normal queue
     var q = queue(worker, concurrency);
+    var processingScheduled = false;
 
     q._tasks = new Heap();
 
@@ -55,7 +56,13 @@ export default function(worker, concurrency) {
             q._tasks.push(item);
         }
 
-        setImmediate(q.process);
+        if (!processingScheduled) {
+            processingScheduled = true;
+            setImmediate(() => {
+                processingScheduled = false;
+                q.process();
+            });
+        }
     };
 
     // Remove unshift function