1

我正在使用Async.js 中的并行函数，由于某种原因，最终的回调没有被执行，我没有看到任何地方发生错误。

我正在动态创建一个传递给并行调用的函数数组，如下所示：

// 'theFiles' is an array of files I'm working with in a code-generator style type of scenario
var callItems = [];
theFiles.forEach(function(currentFile) {

      var genFileFunc = generateFileFunc(destDir + "/" + currentFile, packageName, appName);

      callItems.push(genFileFunc(function(err, results) {
        if(err) {
          console.error("*** ERROR ***" + err);
        } else {
          console.log("Done: " + results);  
        }

      }));

    });

    async.parallel(callItems, function(err, results) {
      console.log(err);
      console.log(results);
      if(err) {
        console.error("**** ERROR ****");
      } else {
        console.log("***** ALL ITEMS HAVE BEEN CALLED WITHOUT ERROR ****");  
      }
    });

然后在一个外部函数中（在上面执行 forEach 的函数之外）我有 generateFileFunc() 函数。

// Function that returns a function that works with a file (modifies it/etc). 
function generateFileFunc(file, packageName, appName) {
  return function(callback) {
    generateFile(file, packageName, appName, callback);
  }
}

我看过这篇 SO 帖子，它帮助我到达了我所在的位置。但是最终的回调没有被执行。并行调用中的所有项目都在执行。在最底部的 gnerateFile (function) 内部，我调用了回调，所以这是金色的。

任何人都知道为什么这可能无法正常执行？

最终结果是并行处理每个函数调用，然后在我完成时收到通知，以便我可以继续执行其他一些指令。

谢谢！

4

3 回答 3

4

逐行分析正在发生的事情，从以下开始：

var genFileFunc = generateFileFunc(...);

由于您的函数generateFileFunc返回函数，因此变量genFileFunc是以下函数

genFileFunc === function(callback) {
    generateFile( ... );
};

现在很明显，这个函数什么都不返回（没有return语句）。显然，我完全理解 JavaScript 的内置undefined常量。特别是你有

genFileFunc(function(err, results) { ... } ) === undefined

这是调用它的结果。因此你推undefined到callItems. 难怪它不起作用。

如果不知道究竟是做什么的，很难说出如何解决这个generateFile问题，但无论如何我都会尝试。尝试简单地这样做：

callItems.push(genFileFunc);

因为您必须将函数推送到callItems，而不是函数的结果，即undefined.

于 2012-09-09T19:41:19.890 回答
2

好奇的。

迄今为止最好的猜测：在 generateFile 内部，返回回调而不是调用它。

于 2012-09-09T19:30:49.887 回答
1

您可以通过以下方式实现既定目标

async.map(theFiles, function(file, done) {
  generateFile(destDir + "/" + file, packageName, appName, done);
}, function(err, res) {
  // do something with the error/results
});
于 2012-09-09T21:10:46.270 回答