学习是最好的投资!
当然咯,因为你并发量是5,但是你的queue中并没有fork callback,所以并发量是5,没有结束也不会调新的咯。
fork callback
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 }) }
雷雷
少了回调
用于处理排队任务的异步函数,完成后必须调用其回调(err)参数,并使用可选错误作为参数。如果您想处理单个任务的错误,请将回调传递给 q.push()。通过(任务、回调)调用。
当然咯,因为你并发量是5,但是你的queue中并没有
fork callback
,所以并发量是5,没有结束也不会调新的咯。雷雷
少了回调
用于处理排队任务的异步函数,完成后必须调用其回调(err)参数,并使用可选错误作为参数。如果您想处理单个任务的错误,请将回调传递给 q.push()。通过(任务、回调)调用。