使用回调节点异步并行

Question

我有几个函数可以并行执行。使用async.parallel()可以正常工作，但在收到错误时执行主回调。

由于功能是独立的，我仍然希望来自其他人的结果，即使有错误。

这是我目前的代码。我的需求是否有另一个async函数？

var async=require('async'); 
async.parallel({ 
    one:function(callback) 
    { 
     callback(null,1); 
    }, 
    two:function(callback) 
    { 
     callback("ERROR Occured"); 
    }, 
    three:function(callback) 
    { 
     callback(null,3); 
    }, 
    four:function(callback) 
    { 
     callback(null,4); 
    } 
},function(err,result) 
{ 
    console.log(err); 
    console.log(result); 
}); 

Answer 1

您可以使用reflectAll：

var async = require('async'); 

async.parallel(async.reflectAll([ 
    function(callback) { 
    callback(null,1); 
    }, 
    function(callback) { 
    callback("ERROR Occured"); 
    }, 
    function(callback) { 
    callback(null,3); 
    }, 
    function(callback) { 
    callback(null,4); 
    } 
]), function(err,result) { 
    console.log(err); 
    console.log(result); 
}); 

这是如何工作的解释here：

包装在另一个函数的函数，总是即使返回数据时，它的错误。返回的对象具有属性error或value。