fix unneeded iteration in queue.resume. Fixes #758

1 files changed, 2 insertions, 1 deletions

diff --git a/lib/async.js b/lib/async.js
index a1650a7..bbb3495 100644
--- 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);
                 }
             }