伊谢尔伦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()。通过(任务、回调)调用。