伊谢尔伦2017-04-17 14:57:30
當然咯,因為你並發量是5,但是你的queue中並沒有fork callback
,所以並發量是5,沒有結束也不會調新的咯。
var async = require('async');
var q = async.queue(function(data, callback) {
console.log(data.name);
// fork callback
callback();
}, 5);
for(var i = 0; i < 10; ++i) {
q.push({ name: 0 })
}
高洛峰2017-04-17 14:57:30
雷雷
少了回呼
用於處理排隊任務的非同步函數,完成後必須呼叫其回呼(err)參數,並使用可選錯誤作為參數。如果您想處理單一任務的錯誤,請將回呼傳遞給 q.push()。透過(任務、回調)呼叫。