然后在Promise.all完成之前执行



我有一段代码,我希望所有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),但行为仍然存在。我用这个更改更新了上面的代码。

我希望所有chargeCreatePromisesorderUpdatePromises执行之前完成执行

当您在循环中同时调用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);
});
}

相关内容

  • 没有找到相关文章