fix unneeded iteration in queue.resume. Fixes #758

caolan · May 20, 2015 · 91f6fb3 · 91f6fb3
1 parent 39715f4
commit 91f6fb3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/async.js b/lib/async.js
@@ -974,9 +974,10 @@
             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 <= q.concurrency; w++) {
+                for (var w = 1; w <= resumeCount; w++) {
                     async.setImmediate(q.process);
                 }
             }