我有一个 id 数组,我想为每个 id 发出一个 api 请求,但我想控制每秒发出多少个请求,或者更好的是,任何时候只有 5 个打开的连接,并且当连接打开时完成,获取下一张。
目前我有这个,它只是同时触发所有请求:
_.each([1,2,3,4,5,6,7,8,9,10], function(issueId) {
github.fetchIssue(repo.namespace, repo.id, issueId, filters)
.then(function(response) {
console.log('Writing: ' + issueId);
writeIssueToDisk(fetchIssueCallback(response));
});
});
就我个人而言,我会使用蓝鸟的.map()
与concurrency
选项,因为我已经在使用 Promise 和 Bluebird 进行任何异步操作。但是,如果您想了解限制一次可以运行的并发请求数的手动编码计数器方案是什么样子,请参阅以下方案:
function limitEach(collection, max, fn, done) {
var cntr = 0, index = 0, errFlag = false;
function runMore() {
while (!errFlag && cntr < max && index < collection.length) {
++cntr;
fn(collection[index++], function(err, data) {
--cntr;
if (errFlag) return;
if (err) {
errFlag = true;
done(err);
} else {
runMore();
}
});
}
if (!errFlag && cntr === 0 && index === collection.length) {
done();
}
}
runMore();
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)