diff options
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index e357447..3fe394a 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -53,11 +53,13 @@ export default function queue(worker, concurrency, payload) { return function(err){ numRunning -= 1; + for (var i = 0, l = tasks.length; i < l; i++) { var task = tasks[i]; + var index = indexOf(workersList, task, 0); if (index >= 0) { - workersList.splice(index) + workersList.splice(index, 1); } task.callback.apply(task, arguments); @@ -118,11 +120,11 @@ export default function queue(worker, concurrency, payload) { for (var i = 0; i < l; i++) { var node = q._tasks.shift(); tasks.push(node); + workersList.push(node); data.push(node.data); } numRunning += 1; - workersList.push(tasks[0]); if (q._tasks.length === 0) { q.empty(); |