diff options
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 87c99f8..3e7eb1e 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -45,6 +45,9 @@ export default function queue(worker, concurrency, payload) { if (q.tasks.length === q.concurrency) { q.saturated(); } + if (q.tasks.length <= (q.concurrency - q.buffer) ) { + q.unsaturated(); + } }); setImmediate(q.process); } @@ -78,6 +81,8 @@ export default function queue(worker, concurrency, payload) { concurrency: concurrency, payload: payload, saturated: noop, + unsaturated:noop, + buffer: concurrency / 4, empty: noop, drain: noop, started: false, |