JS 等待回调在循环内完成

Question

我的节点 js 应用程序中有一个 for 循环；在每次迭代的这个循环中，可以执行一个 mysql 查询（并不总是，取决于）；查询是异步的，我在成功回调中得到结果；但我需要 for 循环的每次迭代都等待回调完成（如果需要）：

function calculate() {
    var resArray = [];

    //[...]

    for (i = 0; i < tables.length; i++) {
        if (id !== undefined) {
            var queryString = ...  //build query
            sequelize.query(queryString).success(function(result) {   //executes query
                id = result[0].id;

                //do stuff with id returned by the query
                //...
                //resArray.push( //push in resArray the result of stuff done above )
            });  
       }
       else {
           //do other kind of stuff and push result in resArray
       }
   }
   return resArray;
}

如果 id != undefined，则执行查询，但 for 循环不等待成功回调，并且函数返回不完整的 resArray。

我该怎么做（或如何重新组织代码）来完成这项工作？ （我正在使用 node js，我没有可能使用 jQuery）。

Answer 1

感谢 Amadan 的建议，我使用混合方法（带有承诺和计数器）摆脱了这个问题；

我真的很想听听您对此的看法以及您是否有改进建议；

首先，我在项目中添加了 q 库 (npm install q) 以使用 Promise。 感谢 q 我已经能够将 sequelize.query （基于回调）包装在一个返回承诺的函数中； Promise 的计数器会在内存中保存未决的 Promise 数量，并且包装函数 executeQuery 在每个 Promise 被解决时将其递减；

(cycle()函数中的for循环执行4次循环；执行2次查询和2次简单日志； 目标是“完成”日志仅在 for 循环结束并且所有承诺都解决后才会发送到屏幕

var id = req.params.id;
var counter = 0;
var endCycle = false;

var queryString = 'SELECT * FROM offers WHERE id = ' + id;

function query () {
    var deferred = Q.defer();
    sequelize.query(queryString).success(function(result) {
        console.log('obtained result');
        deferred.resolve(result);
    });
    return deferred.promise;
}

function executeQuery() {
    query().then(function() {
        console.log('after');
        counter --;
        console.log(counter);
        finished();
    });
}

function finished() {
    if ((counter === 0) && (endCycle)) {
        console.log('finished');
        endCycle = false;
    }
}

function cycle() {
    var result;

    for (i = 0; i <= 3; i ++) {
        if (i > 1) {
            counter ++;
            executeQuery();
        }
        else {
            console.log('else');
        }
    }

    endCycle = true;
    finished();
}

cycle();

---

------------------ 更新 ------------- --------------------------------

根据hugomg 的建议，我更新了代码，使其更简洁： 我将每个 promise 推送到一个数组中，然后使用 Q.all 等待它们都被解决

var id = req.params.id;
var promisesArray = [];
var endCycle = false;

var queryString = 'SELECT * FROM offers WHERE id = ' + id;
function query () {
    var deferred = Q.defer();
    sequelize.query(queryString).success(function(result) {
        console.log('obtained result');
        deferred.resolve(result);
        finished();
    });
    promisesArray.push(deferred.promise);
}

function finished() {
    if (endCycle) {
        endCycle = false;
        Q.all(promisesArray).then(function() {
            console.log('finished');
        });            
    }
}

function cycle() {
    var result;

    for (i = 0; i <= 3; i ++) {
        if (i > 1) {
            query();
        }
        else {
            console.log('else');
        }
    }
    endCycle = true;
    finished();
}

cycle();

Answer 2

你需要改变你的思维方式。如果calculate 调用一个异步方法，那么您获得其结果的唯一方法不是通过return，而是通过调用另一个回调。在 node.js 中，您不能将函数视为接受输入并返回输出的黑盒；您需要将其视为具有一定未来的过程中的一个步骤。你需要问自己的问题是——“我得到了这些结果；然后呢？”

就像sequelize.query，你告诉它“做这个查询，然后用结果做这个”，你需要能够调用calculate并告诉它“去做这些查询，然后用他们的结果做this”。你没有从sequelize.query 得到回报——你也不应该试图从calculate 得到回报。

Promises 会很好用，但不依赖它们，你可以数数。以下代码有四处变化：

// HERE: take a callback parameter
function calculate(callback) {
    var outstandingRequests = 0;
    var resArray = [];

    //[...]

    for (i = 0; i < tables.length; i++) {
        if (id !== undefined) {
            var queryString = ...  //build query

            // HERE: count how many responses you are expecting
            outstandingRequests++;

            sequelize.query(queryString).success(function(result) {   //executes query
                id = result[0].id;

                //do stuff with id returned by the query
                //...
                //resArray.push( //push in resArray the result of stuff done above )

                // HERE: check if all requests are done
                // if so, the array is as full as it will ever be
                // and we can pass the results on
            }).done(function() {
                if (!(--outstandingRequests)) {
                    callback(resArray);
                }
            });  
       }
       else {
           //do other kind of stuff and push result in resArray
       }
   }
   // HERE: return is useless in asynchronous code
}

然后你可以替换假设的和非功能性的

var resArray = calculate();
console.log("Here's your results:", resArray);

与

calculate(function(resArray) {
    console.log("Here's your results:", resArray);
});

编辑：将倒计时放入done 处理程序以解决可能的错误。