node.js中for循环完成后的回调

Question

我需要一些关于node.js异步特性的帮助。我有一个for循环，它从数据库收集数据。 “结果”是一个数组，然后应该返回到主函数。

user_collection.findOne({ 
      _id : uid 
     }, function(error, user) { 
      if(error) 
       callback(error) 
      else { 
       for(var j = 0; j < user.contacts.length; j++) { 
        if(user.contacts[j].accepted == 'true') { 
         user_collection.findOne({ 
          _id : user.contacts[j].contactId 
         }, function(error, user) { 
          result.push(user); 
         }) 
        } 
       } 
       callback(null, result); // This callback executes before the for-loop ends, ofc 
      } 
     }); 

如何确保循环完成后执行回调？

Answer 1

你可能要考虑使用助手库像异步 https://github.com/caolan/async

它有助于保持代码更加一致..

在你的情况，你可以看看forEach()方法

forEach(arr, iterator, callback) 

使用列表中的项目调用迭代器，并在完成时调用回调函数。

结帐为例子

https://github.com/caolan/async/blob/master/mocha_test/each.js

Answer 2

随着Async.js的V1.5.2单元测试，这是each。

each(arr, iterator, [callback]) 

ARR - 一个数组遍历。
迭代器（item，callback） - 应用于arr中每个项目的函数。
回调（错误） - 可选。 所有迭代器函数已完成或发生错误时调用的回调。

Answer 3

使用ES6诺言 （一个承诺库可用于旧的浏览器）：

过程保证同步执行（例如，1，然后2然后3）

function asyncFunction (item, cb) { 
    setTimeout(() => { 
    console.log('done with', item); 
    cb(); 
    }, 100); 
} 

let requests = [1, 2, 3].reduce((promiseChain, item) => { 
    return promiseChain.then(new Promise((resolve) => { 
     asyncFunction(item, resolve); 
    })); 
}, Promise.resolve()); 

requests.then(() => console.log('done')) 

处理所有异步请求，而不所有请求“同步” 执行（2可以更快地完成比1）

let requests = [1,2,3].map((item) => { 
    return new Promise((resolve) => { 
     asyncFunction(item, resolve); 
    }); 
}) 

Promise.all(requests).then(() => console.log('done')); 

我做到了对这样

Promise.all(body.schedules.map(function(scheduleId) { 
     return new Promise(function(resolve, reject) { 
      return scheduleSchema.findOneAndRemove({ 
        _id: scheduleId 
       }) 
       .then(function() { 
        logSchema.insert({ 
         userId: req.user.id, 
         actId: constants.LOG_SCHEDULE_DELETE.id, 
         extData: scheduleId 
        }); 
        resolve(); 
       }) 
       .catch(function(err) { 
        reject(err); 
       }); 
     }); 
    })).then(function() { 
     return res.json({ 
      code: constants.SUCCESS_CODE 
     }); 
    }).catch(function(err) { 
     return res.json(constants.DATABASE_ERROR); 
    }); 

最后一个例子

function callback (result) { console.log('all done'); } 

[1, 2, 3].forEach((item, index, array) => { 
    asyncFunction(item,() => { 
    if (index === array.length - 1) { 
     callback(); 
    } 
    }); 
}); 

这并不能保证所有的项目都处理后回调将执行。它只保证在处理最后一个项目后执行回调。

More information

迈克尔。