在JavaScript中的for循环中调用异步函数

Question

我有以下代码:

for(var i = 0; i < list.length; i++){
    mc_cli.get(list[i], function(err, response) {
        do_something(i);
    });
}

mc_cli是与memcached数据库的连接.可以想象,回调函数是异步的,因此可以在for循环结束时执行.此外,以这种方式调用时,do_something(i)它始终使用for循环的最后一个值.

我用这种方式尝试了一个闭包

do_something((function(x){return x})(i)) 

但显然这又是使用for循环索引的最后一个值.

我也尝试在for循环之前声明一个函数,如下所示:

var create_closure = function(i) {
    return function() {
        return i;
    }
}

然后打电话

do_something(create_closure(i)())

但是再次没有成功,返回值始终是for循环的最后一个值.

任何人都可以告诉我,我的闭包装有什么问题吗？我以为我理解了它们,但我无法理解为什么这不起作用.

Answer 1

由于您正在运行数组,因此您可以简单地使用 forEach哪个提供列表项,以及回调中的索引.迭代将有自己的范围.

list.forEach(function(listItem, index){
  mc_cli.get(listItem, function(err, response) {
    do_something(index);
  });
});

Answer 2

这是异步函数在循环内的范例,我通常使用立即调用的匿名函数来处理它.这确保了使用索引变量的正确值调用异步函数.

好,太棒了.所以所有异步函数都已启动,循环退出.现在,由于它们的异步性质或它们将以何种顺序完成,因此无法确定这些功能何时完成.如果你有代码需要等到所有这些函数在执行之前完成,我建议保持一个简单的计数已完成的函数数:

var total = parsed_result.list.length;
var count = 0;

for(var i = 0; i < total; i++){
    (function(foo){
        mc_cli.get(parsed_result.list[foo], function(err, response) {
            do_something(foo);
            count++;
            if (count > total - 1) done();
        });
    }(i));
}

// You can guarantee that this function will not be called until ALL of the
// asynchronous functions have completed.
function done() {
    console.log('All data has been loaded :).');
}

Answer 3

我知道这是一个老线程,但无论如何添加我的答案.ES2015 let具有在每次迭代时重新绑定循环变量的功能,因此它在异步回调中维护循环变量的值,因此您可以尝试以下方法:

for(let i = 0; i < list.length; i++){
    mc_cli.get(list[i], function(err, response) {
        do_something(i);
    });
}

但无论如何,最好使用forEach或使用立即调用的函数创建一个闭包,因为它let是ES2015功能,可能不支持所有浏览器和实现.从这里开始,Bindings ->let->for/for-in loop iteration scope我可以看到它在Edge 13之前不支持,甚至直到Firefox 49(我还没有在这些浏览器中检查过).它甚至表示它不支持Node 4,但我个人测试过它似乎得到了支持.

Answer 4

你非常接近,但你应该通过闭包get而不是把它放在回调中:

function createCallback(i) {
    return function(){
        do_something(i);
    }
}


for(var i = 0; i < list.length; i++){
    mc_cli.get(list[i], createCallback(i));
}

Answer 5

使用async/await语法和Promise

(async function() {
    for(var i = 0; i < list.length; i++){
        await new Promise(next => {
            mc_cli.get(list[i], function(err, response) {
                do_something(i); next()
            })
        })
    }
})()

这将在每个周期中停止循环，直到next()触发功能