javascript - 如何限制 api 请求堆栈？

Question

我有一个 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));
        });
});

Answer 1

就我个人而言，我会使用 Bluebird 的 .map() 和 concurrency 选项，因为我已经将 promises 和 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();
}