diff options
Diffstat (limited to 'lib')
-rw-r--r-- | lib/async.js | 3 |
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); } } |