diff options
| -rw-r--r-- | lib/internal/queue.js | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index b06f12e..4f57edb 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -18,8 +18,8 @@ export default function queue(worker, concurrency, payload) { var _worker = wrapAsync(worker); var numRunning = 0; var workersList = []; - var isWaitingForProcessing = false; + var processingScheduled = false; function _insert(data, insertAtFront, callback) { if (callback != null && typeof callback !== 'function') { throw new Error('task callback must be a function'); @@ -48,9 +48,12 @@ export default function queue(worker, concurrency, payload) { } } - if (!isWaitingForProcessing) { - isWaitingForProcessing = true; - setImmediate(q.process); + if (!processingScheduled) { + processingScheduled = true; + setImmediate(function() { + processingScheduled = false; + q.process(); + }); } } @@ -111,8 +114,6 @@ export default function queue(worker, concurrency, payload) { q._tasks.remove(testFn); }, process: function () { - isWaitingForProcessing = false; - // Avoid trying to start too many processing operations. This can occur // when callbacks resolve synchronously (#1267). if (isProcessing) { |