代码如下:
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吧
});