嵌套for循环MongoDB中的Javascript异步

Question

我有一个嵌套在另一个 for 循环中的 for 循环内的异步函数。

// recipesArray is an array of arrays of objects
// recipeObject is an array of objects
// currentRecipe is an object

connectToDb(function(){
   // LOOP 1
   for (var i=0, l=recipesArray.length; i < l; i++) {
      // recipeObject is an 
      var recipeObject = recipesArray[i];

      // LOOP 2
      for (var x=0, y=recipeObject.length; x < y; x++) {
         var currentRecipe = recipeObject[x];

         // this is an asynchronous function
         checkRecipe(currentRecipe, function (theRecipe) {
            if (theRecipe === undefined) {
               console.log('RECIPE NOT FOUND');
            } else {
               console.log('RECIPE FOUND', theRecipe);
            }
         });
      }
   }
});

我需要根据 checkRecipe 函数的结果向 recipesArray 添加数据。

我一直在尝试不同的东西... - 我是否尝试跟踪 i 和 x... - 我是否尝试有多个回调... - 我什至需要做所有这些，还是有其他方法....

我也尝试使用 node 的异步库（实际上在其他情况下非常有帮助），但是 forEach 不接受对象（只有一个数组）。

卡住了。

任何建议将不胜感激。

Answer 1

假设checkRecipe() 可以无限制地并行运行，以下是您可以如何使用async.each()：

connectToDb(function() {
  async.each(recipesArray, function(subArray, callback) {
    async.each(subArray, function(currentRecipe, callback2) {
      checkRecipe(currentRecipe, function(theRecipe) {
        if (theRecipe === undefined)
          return callback2(new Error('Recipe not found'));
        callback2();
      });
    }, callback);
  }, function(err) {
    if (err)
      return console.error('Error: ' + err);

    // success, all recipes found
  });
});