expose tasks array for queues

antz29 · Nov 1, 2011 · 25f2dbf · 25f2dbf
1 parent e0ef3d8
commit 25f2dbf
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/dist/async.min.js b/dist/async.min.js
diff --git a/lib/async.js b/lib/async.js
@@ -587,34 +587,34 @@
 
     async.queue = function (worker, concurrency) {
         var workers = 0;
-        var tasks = [];
         var q = {
+            tasks: [],
             concurrency: concurrency,
             saturated: null,
             empty: null,
             drain: null,
             push: function (data, callback) {
-                tasks.push({data: data, callback: callback});
-                if(q.saturated && tasks.length == concurrency) q.saturated();
+                q.tasks.push({data: data, callback: callback});
+                if(q.saturated && q.tasks.length == concurrency) q.saturated();
                 async.nextTick(q.process);
             },
             process: function () {
-                if (workers < q.concurrency && tasks.length) {
-                    var task = tasks.shift();
-                    if(q.empty && tasks.length == 0) q.empty();
+                if (workers < q.concurrency && q.tasks.length) {
+                    var task = q.tasks.shift();
+                    if(q.empty && q.tasks.length == 0) q.empty();
                     workers += 1;
                     worker(task.data, function () {
                         workers -= 1;
                         if (task.callback) {
                             task.callback.apply(task, arguments);
                         }
-                        if(q.drain && tasks.length + workers == 0) q.drain();
+                        if(q.drain && q.tasks.length + workers == 0) q.drain();
                         q.process();
                     });
                 }
             },
             length: function () {
-                return tasks.length;
+                return q.tasks.length;
             },
             running: function () {
                 return workers;