使用async.js在循环中执行异步操作

Question

我知道我要发布这个，然后得到它的工作，更不用说标题，但...

我处于我需要的情况对我给出的数组中的每个元素执行一些异步代码，然后在所有元素完成后进行一些检查。通常情况下，如果我在这里使用async.js，但是我所做的事情并没有得到我想要的结果。

所以这是我的逻辑，我想我可以创建一个函数数组，但我做的方式，这似乎有async.js返回我的功能表中的结果。

findLeadThatCanBeTaken : (leads, user, manualTake, cb) => 
    if(leads.length == 0) then return cb(null, null) 

    funcArr = [] 
    self = this 

    for lead in leads 
    fun = (callback) -> 
     console.log(lead.state) 
     State.get lead.state, (e, state) -> 
     if !state or state.canBeCalled(self.currentTime()) 
      return callback(null, lead._id.toString) 

     return callback(null, null) 

    funcArr.push(fun) 

    async.parallel funcArr, (e, r) -> 
    if (e) 
     return cb(message:'No leads can be called at the current time', null) 

    id = _.compact(r) 
    id = r[0] if r.length 

    if (!id || !id.length) 
     return cb(message:'No leads can be called at the current time', null) 

    lead = _.filter leads, (l) -> return l._id.toString() == id 

    # Code handling 
    @takeLead(lead, user, cb) 

我90％肯定的问题是这阵我创造不被分配了类似的我想是的，但我不知道。任何人都知道我在这里做错了什么？

Answer 1

我猜你有一个经典的“一环内关闭”的问题：

for lead in leads 
    fun = (callback) -> 
    # some stuff that uses 'lead'... 

的问题是，所有的fun功能将有完全相同的lead的引用，当这些功能的，lead将引用它在循环中的最后一个值。

从fine manual（该部分的底部）：

当使用JavaScript的循环产生的功能，这是常见的，以便插入一个封闭的包装，以保证循环变量被关闭了，所有的生成的函数不只是分享最终值。 CoffeeScript提供了do关键字，该关键字立即调用传递的函数，转发任何参数。

听起来很熟悉吗？你可能想要得到的lead在每次迭代的价值，而不仅仅是拖动周围lead本身是这样的：

for lead in leads 
    do (lead) -> 
    fun = (callback) -> 
     # What you have now...