Clean up

caolan · Oct 28, 2015 · 259c26c · 259c26c
1 parent 19f0d0f
commit 259c26c
Showing 1 changed file with 13 additions and 18 deletions.
diff --git a/lib/async.js b/lib/async.js
@@ -929,28 +929,23 @@
                 _insert(q, data, true, callback);
             },
             process: function () {
-                if (!q.paused && workers < q.concurrency && q.tasks.length) {
-                    while(workers < q.concurrency && q.tasks.length){
-                        if (q.paused) {
-                            return;
-                        }
+                while(!q.paused && workers < q.concurrency && q.tasks.length){
 
-                        var tasks = q.payload ?
-                            q.tasks.splice(0, q.payload) :
-                            q.tasks.splice(0, q.tasks.length);
+                    var tasks = q.payload ?
+                        q.tasks.splice(0, q.payload) :
+                        q.tasks.splice(0, q.tasks.length);
 
-                        var data = _map(tasks, function (task) {
-                            return task.data;
-                        });
+                    var data = _map(tasks, function (task) {
+                        return task.data;
+                    });
 
-                        if (q.tasks.length === 0) {
-                            q.empty();
-                        }
-                        workers += 1;
-                        workersList.push(tasks[0]);
-                        var cb = only_once(_next(q, tasks));
-                        worker(data, cb);
+                    if (q.tasks.length === 0) {
+                        q.empty();
                     }
+                    workers += 1;
+                    workersList.push(tasks[0]);
+                    var cb = only_once(_next(q, tasks));
+                    worker(data, cb);
                 }
             },
             length: function () {