1 files changed, 3 insertions, 1 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index fdbabbc..fffea99 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -115,8 +115,10 @@ export default function queue(worker, concurrency, payload) {
                 trigger('unsaturated')
             }
 
-            if (q.idle()) {
+            if (q.idle() && !drainScheduled) {
+                drainScheduled = true
                 trigger('drain')
+                drainScheduled = false
             }
             q.process();
         };