我有一段代码,我希望所有chargeCreatePromises在orderUpdatePromises执行之前完成执行:
return Q.all(chargeCreatePromises)
.then(function() {
return Q.all(orderUpdatePromises)
})
代码的结构如下:
function createForThisMonth(order) {
return Q.all([
Order.findOne({ _id: order._id }),
Charge.findOne({
"orders._id": order._id,
chargeMonth: moment().format("YYYY-MM")
})
]).spread(function(order, charge) {
console.log("completed: ", order.completed)
if (!charge && !order.completed) {
return createChargeFromOrder(order)
// returns a promise with Charge.findOrCreate(newCharge);
}
})
}
function orderUpdate(order) {
return Q(Order.findOneAndUpdate({
{ _id: order._id },
{ $set: { completed: true } }
}))
}
function process(orders) {
var chargeCreatePromises = [];
var orderUpdatePromises = [];
orders.forEach(function(order) {
if (order.category === 'monthly') {
chargeCreatePromises.push(createForThisMonth(order))
}
orderUpdatePromises.push(orderUpdate(order))
})
return Q.allSettled(chargeCreatePromises)
.then(function() {
return Q.all(orderUpdatePromises)
})
}
在不同的执行中,日志是:
completed: true
completed: false
completed: false
completed: true
completed: false
所以,我认为有时候then(Q.all(orderUpdatePromises))
在Q.all(chargeCreatePromises)
完成之前就已经执行了。
有人能帮助我了解这里发生了什么并实现我的目标吗?
问题->https://github.com/kriskowal/q
节点4
编辑:
我将Q.all(chargeCreatePromises)
更改为Q.allSettled(chargeCreatePromises)
,但行为仍然存在。我用这个更改更新了上面的代码。
我希望所有
chargeCreatePromises
在orderUpdatePromises
执行之前完成执行
当您在循环中同时调用createForThisMonth(…)
和orderUpdate(…)
时,执行就开始了。Q.all
代码只等待它们,但它们将并发运行并以任何顺序完成。
如果您希望所有chargeCreatePromises
首先完成,请将对orderUpdate(…)
的调用放在.then()
处理程序中:
function process(orders) {
var chargeCreatePromises = orders.filter(function(order) {
return order.category === 'monthly';
}).map(createForThisMonth);
return Q.allSettled(chargeCreatePromises).then(function() {
var orderUpdatePromises = orders.map(orderUpdate);
return Q.all(orderUpdatePromises);
});
}