diff options
author | Alexander Early <aearly@fluid.com> | 2015-05-20 16:20:44 -0700 |
---|---|---|
committer | Alexander Early <aearly@fluid.com> | 2015-05-20 16:20:44 -0700 |
commit | 91f6fb305f860086fbb388c7ae7665eea39fde74 (patch) | |
tree | 0b1d3473a98f06280e1c8d5f1b650b6c7a047ecf | |
parent | 39715f48f23dc36cb0e8ebe44dde16ca07a04b06 (diff) | |
download | async-91f6fb305f860086fbb388c7ae7665eea39fde74.tar.gz |
fix unneeded iteration in queue.resume. Fixes #758
-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); } } |