很多情況下,使用async.series和async.paralle存在一個明顯的問題,即:
1.其任務隊列是靜態的,在其調用前,一定要明確任務隊列的數量,一旦明確了任務隊列的數量,就不能改變.
2.倘如要同時并發讀取上千個文件,使用async.paralle明顯不可能(各線程搶資源,根本不夠用),使用async.series…(運行時間可想而知…)

好在有一種async.queue方法:

// async.queue
var async = require('async');
function worker(data, callback) {console.log(data);callback();
}
var concurrency = 2;
var queue = async.queue(worker, concurrency);
queue.push(1);
queue.push(2);
queue.push(3);// 注:async.queue有2個參數:worker函數和concurrency(并發度)
// concurrency比較好理解,即并發的最大數量(本例為:2),
// worker函數,是處理數據的方式,它接受2個參數(data, callback);

// queue.drain
// 可以給queue隊列加一個完工事件處理
var async = require('async');
function worker(data, callback) {setTimeout(callback, data);
}
var concurrency = 2;
var queue = async.queue(worker, concurrency);
var start = new Date;
queue.drain = function() {console.log('Completed in ' + (new Date - start) + 'ms');
};queue.push([100, 300, 200]);// 注:以上函數會執行2次循環,每次循環會總隊列中讀取2個數據(第一次100和300,第二次200);
// 2次循環過后會執行drain函數,打印出'Completed'字符串和時間.

參考《JavaScript異步編程》 — 設計快速響應的網絡應用 P80~P82