多次调用同一个函数并处理组合结果集答案

【问题标题】：Call same function many times and process combined result set多次调用同一个函数并处理组合结果集
【发布时间】：2015-03-02 02:39:54
【问题描述】：

我需要发出几个 API 请求，然后对组合结果集进行一些处理。在下面的示例中，您可以看到通过复制相同的请求代码发出了 3 个请求（到 /create），但是我希望能够指定要发出多少个请求。例如，我可能希望运行相同的 API 调用 50 次。

如何在不重复n次API调用函数的情况下进行n次调用？

async.parallel([
    function(callback){
        request.post('http://localhost:3000/create')
            .send(conf)
            .end(function (err, res) {
                if (err) {
                    callback(err, null);
                }
                callback(null, res.body.id);
            });
    },
    function(callback){
        request.post('http://localhost:3000/create')
            .send(conf)
            .end(function (err, res) {
                if (err) {
                    callback(err, null);
                }
                callback(null, res.body.id);
            });
    },
    function(callback){
        request.post('http://localhost:3000/api/store/create')
            .send(conf)
            .end(function (err, res) {
                if (err) {
                    callback(err, null);
                }
                callback(null, res.body.id);
            });
    }
],
function(err, results){
    if (err) {
        console.log(err);
    }
 // do stuff with results
});

【问题讨论】：

标签： node.js function asynchronous code-duplication

【解决方案1】：

首先，将要多次调用的代码包装在一个函数中：

var doRequest = function (callback) {
    request.post('http://localhost:3000/create')
        .send(conf)
        .end(function (err, res) {
            if (err) {
                callback(err);
            }
            callback(null, res.body.id);
        });
}

然后，使用async.times 函数：

async.times(50, function (n, next) {
    doRequest(function (err, result) {
      next(err, result);
    });
}, function (error, results) {
  // do something with your results
}

【讨论】：

async.times 函数似乎并不平行
在调用下一个之前不会等待一个调用完成。这就是与async.timesSeries 的区别。
为什么回调有一个名字next？此函数的行为在文档中并不明显......
刚刚做了一个测试。 async.times 就是答案！它完全按照要求的方式运行。 next 文档中的回调名称具有误导性。只是确认操作结束并返回结果的回调。
next 回调不会误导async 库 IMO 中实现这些迭代器函数的方式，因为它被用于调用下一步。我认为可能让您感到困惑的是async 库中的parallel 概念并不意味着所有50 个调用都将同时执行。只是表示每一步都将被调用，无需等待上一步回调返回。

【解决方案2】：

创建一个数组，其中包含尽可能多的引用函数，因为您需要工作负载中的任务。然后将它们传递给async.parallel。例如：

var async = require("async");

var slowone = function (callback) {
        setTimeout(function () {
                callback(null, 1);
        }, 1000);
};

async.parallel(
        dd(slowone, 100), 
        function (err, r) {
                console.log(JSON.stringify(r));
        }
);

// Returns an array with count instances of value.
function dd(value, count) {
        var result = [];

        for (var i=0; i<count; i++) {
                result.push(value);
        }

        return result;
}

再次注意，尽管有很多引用，但慢速运行函数只有一个实例。

【讨论】：