API调用的异步并行与node.js中的回调

Question

我需要等待两个 API 回调函数的任务，当任务完成后，我希望收到一个回调，这样我就可以使用来自这两个函数的数据。

我希望该函数将被并行执行...我阅读了很多关于 async.parallel 的问题，但我找不到将这些函数与 async 一起使用的方法。

当然 async 只是一个例子，如果可行，任何其他方式都可以。

对不起，我的英语不好，我希望代码更容易理解。

谢谢

var dataFunctionA = "";
var dataFunctionB = "";

var callbackFunctionA = function(err, response, data) {
  // do some work with data
  dataFunctionA = "Hello";
}

var callbackFunctionB = function(err, response, data) {
  // do some work with data
  dataFunctionB = " World!";
}

function printHelloWorld(){
   console.write(dataFunctionA + dataFunctionB);
}


APIClient.functionA(paramA, callbackFunctionA);

APIClient.functionB(paramB, callbackFunctionB);

// need to wait for the two callbacks
printHelloWorld();

Answer 1

使用async.parallel，您可以通过以下方式实现：

async.parallel({
    functionA: APIClient.functionA.bind(null, paramA),
    functionB: APIClient.functionB.bind(null, paramB)

}, function(error, results) {
    processCallbacks(error, results);
});

在你的函数中，完成数据处理后你应该调用传递的隐式并行回调。

functionA(paramA, callback) {
   // data processing
   callback(null, resultFromProcessingParamA);
}

您在这里所做的是将函数对象传递给并行。此处使用对象的键，以便您可以访问结果数组。对于上面的例子，functionA的结果会保存在results.functionA中，以此类推。

第一个参数为空（由于 .bind），然后您传递所有其他需要的参数。回调由函数之间的parallel自动传递，只有在所有函数完成后才会调用最后一个回调。

请运行以下 sn -p 以更好地理解。

function functionA (paramA, callback) {
  $('body').append('<p> Parallel execution of function A and waiting for 5 seconds, parameter passed: ' + paramA + '</p>');
  setTimeout(function(){
        $('body').append('<p>processed functionA</p>');
    callback(null, ++paramA);
  }, 5000);
}

function functionB (paramB, callback) {
  $('body').append('<p> Parallel execution of function B and waiting for 1 second, parameter passed: ' + paramB + '</p>');
  setTimeout(function(){
    $('body').append('<p>processed functionB</p>');
    callback(null, ++paramB);
  }, 1000);
}

function processCallbacks (results) {
  $('body').append('<p> Processing results from two functions. ParamA now is:' + results.functionA + ' and paramB now is:' + results.functionB + '</p>');
}


async.parallel({
  
    functionA: functionA.bind(null, 10),
    functionB: functionB.bind(null, 2)

}, function(error, results) {
  console.log(results);
    if (!error) {
      processCallbacks(results);
    }
  
});

<script src="https://cdnjs.cloudflare.com/ajax/libs/async/1.5.0/async.js"></script>

<script src="https://ajax.googleapis.com/ajax/libs/jquery/2.1.1/jquery.min.js"></script>

Answer 2

如果你不想使用 Promise，你可以这样做：

var dataFunctionA = "";
var dataFunctionB = "";
var dataFunctionCount = 2;

function checkDone() {
  dataFunctionCount--;
  if(dataFunctionCount === 0) {
// need to wait for the two callbacks
printHelloWorld();  
  }
}

var callbackFunctionA = function(err, response, data) {
  // do some work with data
  dataFunctionA = "Hello";
  checkDone();
}

var callbackFunctionB = function(err, response, data) {
  // do some work with data
  dataFunctionB = " World!";
  checkDone();
}

function printHelloWorld(){
   console.write(dataFunctionA + dataFunctionB);
}

APIClient.functionA(paramA, callbackFunctionA);

APIClient.functionB(paramB, callbackFunctionB);