node.js - NodeJS + async：选择哪个控制流选项？

Question

如您所知，async.parallel 是用这样的代码定义的：

async.parallel([
    function (callback) {
        callback(err, objects);
    },
    function (callback) {
        callback(err, status);
    },
    function (callback) {
        callback(err, status);
    },
], function (err, results) {
    //smth with results[N] array...
});

并行执行所有任务。objects但是，我需要第一个函数（确切地说，是）的回调结果在第二个和第三个函数中可用。换句话说，第一步——第一个函数，第二个——（第 2 + 3 个与第一个函数的结果平行）。async.waterfall似乎是个坏主意，因为：

1. 在瀑布函数中不能并行工作
2. 我无法访问堆栈的每个结果，只能访问最后一个。

有任何想法吗？谢谢！

Answer 1

你需要waterfall和parallel。

function thing1(callback) {...callback(null, thing1Result);}
function thing2A(thing1Result, callback) {...}
function thing2B(thing1Result, callback) {...}
function thing2(thing1Result, callback) {
    async.parallel([
      async.apply(thing2A, thing1Result),
      async.apply(thing2B, thing1Result)
    ], callback);
}
async.waterfall([thing1, thing2], function (error) {
    //all done
});

Answer 2

没有必要使用异步。使用异步你基本上是对你的应用程序进行黑盒化。因为我不喜欢简单任务的魔法，香草js：

var f1 = function (cb){
    ...
    cb (null, "result from f1"); //null error
};

var f2 = function (resultFromF1, cb){
    ...
    cb (null); //null error
};

var f3 = function (resultFromF1, cb){
    ...
    cb (null); //null error
};


var main = function (cb){
    f1 (function (error, resultFromF1){
        if (error) return cb ([error]);

        var errors = [];
        var remaining = 2;
        var finish = function (error){
            if (error) errors.push (error); 
            if (!--remaining){
                //f2 and f3 have finished
                cb (errors.length ? errors : null);
            }
        };

        f2 (resultFromF1, finish);
        f3 (resultFromF1, finish);
    });
};

main (function (errors){
    if (errors) return handleError (errors); //errors is an array
    ...
});