将数据传递到 node.js 回调 - 异步问题 [重复]

Question

以下面的代码为例，其中一个对象data 使用一些值进行初始化，然后由一些时间密集型函数处理，例如数据库访问。如果函数成功，成功的data 项目的名称将打印到控制台。否则，打印失败通知：

data = {first:  'someinfo',   second:  'somemoreinfo',   third:  'evenmoreinfo'};

for (var item in data) {
    timeIntensiveFunction(item, data[item], function(err) {
        if (!err) {
            console.log(item + ' processed successfully');
        } else {
            console.log(item + ' failed');
        }
    });
}

假设函数对所有三个数据项都成功，您会希望控制台显示此内容：

first processed successfully
second processed successfully
third processed successfully

它会显示这个，假设第一次数据库访问比for循环花费更长的时间：

third processed successfully
third processed successfully
third processed successfully

这是因为控制台日志记录是在回调中完成的，只有在 for 循环完成后才合理地调用 ，因为 timeIntensiveFunction() 需要这样做长。 在调用第一个回调时，item 已经有了它的最后一个值，third。

如何将 item 的“当前”值传递给回调？

Answer 1

问题是因为它只使用最后一项调用回调。

您可以使用如下函数绑定每个项目。

var printStatus = function(item){
    return function(err) {
        if (!err) {
            console.log(item + ' processed successfully');
        } else {
            console.log(item + ' failed');
        }
    }
}

for (var item in data) {
    timeIntensiveFunction(item, data[item], printStatus(item));
}

Answer 2

这是 javascript 中一个常见的带有闭包的“陷阱”。一种解决方法是将您的函数调用包装在一个匿名函数中并重新调整item 的范围。像这样：

for (var item in data) {
    (function(item){
        timeIntensiveFunction(item, data[item], function(err) {
           if (!err) {
               console.log(item + ' processed successfully');
           } else {
               console.log(item + ' failed');
           }
        });
   })(item);
}

Answer 3

如果您正在寻找一个可以更轻松地处理异步任务的库，请查看caolan/async。

var async = require("async");

var data = [{id: "first"}, {id: "second"}, {id: "third"}];

function timeIntensiveFunction(item, done) {
  // do something
  console.log("time intensive task started:", item.id);

  // err?
  // if (err) return done(err);

  done();
}

function processItem(item, done) {
  timeIntensiveFunction(item, function(err) {
    if (err) return done(err);
    console.log("task complete:", item.id);
    done();
  });
}

async.map(data, processItem);

输出

time intensive task started: first
task complete: first
time intensive task started: second
task complete: second
time intensive task started: third
task complete: third

对于希望学习如何在没有库的情况下执行此操作的用户，您可以查看此答案的修订历史记录。