Avoid unnessary queuing of *concurrency processes on resume

caolan · Dec 1, 2016 · 834d5ac · 834d5ac
1 parent 7d51d6f
commit 834d5ac
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/lib/internal/queue.js b/lib/internal/queue.js
@@ -149,12 +149,7 @@ export default function queue(worker, concurrency, payload) {
         resume: function () {
             if (q.paused === false) { return; }
             q.paused = false;
-            var resumeCount = Math.min(q.concurrency, q._tasks.length);
-            // Need to call q.process once per concurrent
-            // worker to preserve full concurrency after pause
-            for (var w = 1; w <= resumeCount; w++) {
-                setImmediate(q.process);
-            }
+            setImmediate(q.process);
         }
     };
     return q;