diff options
author | Graeme Yeates <yeatesgraeme@gmail.com> | 2016-12-01 07:57:19 -0500 |
---|---|---|
committer | Graeme Yeates <yeatesgraeme@gmail.com> | 2016-12-01 07:57:19 -0500 |
commit | 834d5ac5a19d55bb4e493257fa95cdd8682044a4 (patch) | |
tree | 1579bbfdd27340bc9a3296e4f6e37fc1cf24dfd8 /lib | |
parent | 7d51d6fca345080b44ed0a794f982c0965a5223e (diff) | |
download | async-834d5ac5a19d55bb4e493257fa95cdd8682044a4.tar.gz |
Avoid unnessary queuing of *concurrency processes on resumepr/1267
Diffstat (limited to 'lib')
-rw-r--r-- | lib/internal/queue.js | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 15fb950..7a438da 100644 --- 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; |