首页 > javascript/mongoose 在for循环中有一个异步函数,不能得到正确的结果?

javascript/mongoose 在for循环中有一个异步函数,不能得到正确的结果?

代码如下:

   var result = [];
   for (var i = 0; i <array.length ; i++) {
        populateFavoriteItem(accountId,array[i],function(doc){
        result.push(doc);
        //mark 1
        })
      // if (i == array.length - 1) {
      // console.log(result);
      // callback(result);     
      // }  
   }
   //mark 2
   console.log(result);
   callback(result);
   

populateFavoriteItem 是一个异步函数,每次执行之后的callback中,将得到的doc存放到result里面。

实际运行的时候,都是先运行到mark 1,然后再运行到mark2, 所以result一直为空。 我尝试把if条件放到for循环里面,也不可以。

请我应该怎么弄?


var result = [];
var i = 0;
var bLock = false;
while (i<array.length) {
  if (bLock) continue;
  bLock = true;
  populateFavoriteItem(accountId,array[i],function(doc){
    i = result.push(doc);
    bLock = false;
    //mark 1
  })
}
//mark 2
console.log(result);
callback(result);

注:JavaScript不能多线程,也许上面的代码只能在火狐上运行。


使用node.js的 eventEmitter来实现事件的监听和触发:

   var result = [];
   var obj;
   var j = 0;
   var myEventEmitter = new eventEmitter;
   myEventEmitter.on('next',addResult);
   function addResult(){
      result.push(obj)
      j++;
      if (j == array.length) {
        callback(result);
      }
   }
  
   
   var populateFav = promiseify(populateFavoriteItem);           
   for (var i = 0; i <array.length ; i++) {
        var ii = i;
        populateFavoriteItem(accountId,array[ii],function(doc){
          //result.push(doc);
          obj = doc;
          myEventEmitter.emit("next");
        })
   }

我没有用过mongoose,所以不知道你的populateFavoriteItem是只能callback形式使用,还是也可以返回Promise。我现在假设你只能传入callback,然后你可以如下操作:

//这是一个非常简单的可以把populateFavoriteItem转换成Promise形式的转换器
var promiseify = function(func) {
    return function() {
        var ctx = this;
        var parameters = Array.prototype.apply(arguments);

        return new Promise(function(resolve, reject) {
            var cb = function(doc) {
                return resolve.call(this, doc);
            };
            func.apply(ctx, parameters.concat([cb]));
        });
    };
};

var populateFav = promiseify(populateFavoriteItem);

Promise
    .all(array.map(item => populateFav(accountId, item)))
    .then(function(result) {
        //你在这调用callback吧
    });
【热门文章】
【热门文章】