node.js - 使用 forEach 时避免回调多次调用

Question

我有一个处理数据数组(第一个参数)的函数，一旦处理完成，它仅调用一次回调函数(第二个参数)。我使用 forEach 逐项处理数据，包括在一些检查中处理每个项目并将参数存储在数据库中。函数 storeInDB() 执行存储工作，并在存储项目后使用回调(第二个参数)。

代码的第一种方法如下:

function doWork(data, callback) {
    data.forEach(function (item) {
        // Do some check on item
        ...
        storeInDB(item, function(err) {
           // check error etc.
           ...
           callback();
        });
    });
}

但是，这是错误的，因为 callback 函数将被调用多次(与 data 数组中的元素一样多)。

我想知道如何重构我的代码以实现所需的行为，即存储工作完成后仅调用一次callback。我猜async可以帮助完成这项任务，但我还没有找到组合 async + forEach 的正确模式。

感谢任何帮助!

Answer 1

您可以使用诸如async之类的库来执行此操作，尽管我建议如果可能的话使用promise。对于当前的问题，您可以使用计数器来确定已完成多少存储调用，并在总数完成时调用回调。

let counter = 0;
data.forEach(function (item) {
    // Do some check on item
    ...
    storeInDB(item, function(err) {
       // check error etc.
       counter++
       if (counter == data.length) {
         callback();
       }
    });
});