等到 for 循环内的所有函数调用结束其执行 - Javascript

Question

我有一个函数，它在 for 循环中包含另一个函数调用。

outerFunction(){ 
    for (var j = 0; j < geoAddress.length; j++) {
         innerFunction(j);
    }
}

我需要等到对 innerFunction 的所有调用完成。如果我需要并行执行这些函数，如何在 JavaScript 中实现呢？

Answer 1

如果您不想为此使用外部库，您可以创建一个范围对象，例如 process，它会跟踪有多少 innerFunction 调用仍处于未决状态，并在等待时调用外部回调 cb完成了。

这样做的重点是您仍然可以获得异步执行的好处，但您只需确保您的代码在属于 outerFunction 的所有 innerFunction 实际完成之前不会执行下一部分：

outerFunction(function() {
    console.log("All done for outerFunction! - What you should do next?");

    // This block is executed when all innerFunction calls are finished.

});

JavaScript：

// Example addresses
var geoAddress = ["Some address X", "Some address Y"];

var innerFunction = function(geoAddress, process) { 

    // Your work to be done is here...
    // Now we use only setTimeout to demonstrate async method
    setTimeout(function() {

        console.log("innerFunction processing address: " + geoAddress);

        // Ok, we update the process
        process.done();   

    }, 500);

};

var outerFunction = function(cb) { 

    // Process object for tracking state of innerFunction executions
    var process = { 

        // Total number of work ahead (number of innerFunction calls required).
        count: geoAddress.length,

        // Method which is triggered when some call of innerFunction finishes  
        done: function() {

            // Decrease work pool
            this.count--;

            // Check if we are done & trigger a callback
            if(this.count === 0) { 
                setTimeout(cb, 0);
            }            
        }
    };

    for (var j = 0; j < geoAddress.length; j++) {
        innerFunction(geoAddress[j], process);
    }

};

// Testing our program
outerFunction(function() {
    console.log("All done for outerFunction! - What you should do next?");

    // This block is executed when all innerFunction calls are finished.

});

输出：

innerFunction processing address: Some address X
innerFunction processing address: Some address Y
All done for outerFunction! - What you should do next? 

这里是js fiddle example

干杯。

Answer 2

编辑 - 使用 Q Promise 库以节点方式做事

如果您使用的是 Q Promise 库，请尝试以下操作：

outerFunction(){
    var promises = [];

    for (var j = 0; j < geoAddress.length; j++) {
        deferreds.push(innerFunction(j));
    }

    Q.all(promises).then(function(){ 
        // do things after your inner functions run 
    });
}

即使您不使用这个特定的库，原理也是一样的。一个人应该让一个函数返回一个 Promise 或者像 Q.denodify 方法一样将它包装在一个 Promise 中，将所有调用推送到一个 Promise 数组，将所述数组传递给你的库的等效 .when() (jQuery) 或 .all () （Q Promise 库），然后在所有 Promise 都解决后使用 .then() 来做事。

Answer 3

outerFunction() { 
    var done = 0;

    function oneThreadDone() {
        done++;
        if (done === geoAddress.length) {
            // do something when all done
        }
    }

    for (var j = 0; j < geoAddress.length; j++) {
         setTimeout(function() { innerFunction(j, oneThreadDone); }, 0);
    }
}

并在 inner_function 内部调用 oneThreadDone() 函数（通过参数传递引用）

Answer 4

查看异步库。 https://www.npmjs.org/package/async

查看有关“同时”的文档。听起来它可以满足您的需求。 同时（测试，fn，回调）

var count = 0;

async.whilst(
function () { return count < 5; },
function (callback) {
    count++;
    setTimeout(callback, 1000);
},
function (err) {
    // 5 seconds have passed
}

);