使用回調節點異步並行

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。