javascript - Promise all 中的同步循环

Question

我想在我的一部分代码中做一个同步循环。 函数 saveInDatabase 检查项目标题(字符串)是否已经存在于数据库中。这就是它不能并行解决的原因，否则条件永远不会适用(并且会创建重复项)。

Promise.all(arr.map(item => {
     saveInDatabase(item).then((myResult) => ... );
}));

我尝试将此功能封装到单独的 promise 中，也尝试使用 npm 包(synchronous.js、sync)，但它似乎不适合我的代码。

也许这个解决方案是完全愚蠢的。 您认为用同步循环(例如 foreach)替换 promise.all 是更好的主意吗？问题是我需要每次迭代的结果...

我使用的是 Node 6.11.2。你能给我一些技巧来处理这个问题吗？ 先感谢您。

Answer 1

如果不使用 await(它不在 node.js v6.11.2 中，但会使其更简单)，用于序列化一堆返回 promise 的异步操作的经典模式是使用reduce() 循环如下:

arr.reduce(function(p, item) {
    return p.then(function() {
        return saveInDatabase(item).then((myResult) => ... );
    });
}, Promise.resolve()).then(function() {
    // all done here
}).catch(function(err) {
    // error here
});

如果你想保存所有的结果，你可以使用你的.then(myResult => ...)处理程序将结果.push()完成后可以访问的数组。

这将序列化所有对 saveInDatabase(item) 的调用，等待第一个完成后再调用第二个，等待第二个完成再调用第三个等等……

如果 saveInDatabase(item) 拒绝，此处的默认实现将停止。如果你想继续(你没有在你的问题中说)，即使它给出了一个错误，那么你可以添加一个 .catch() 到它来将被拒绝的 promise 变成一个已实现的 promise promise 。

---

在 node.js v7+ 中，您可以在常规 for 循环中使用 await:

async function myFunc() {
    let results = [];
    for (let item of arr) {
        let r = await saveInDatabase(item).then((myResult) => ... );
        results.push(r);
    }
    return results;
}

myFunc().then(function(results) {
    // all done here
}).catch(function(err) {
    // error here
});

---

如果您可以并行运行所有请求，那么您可以这样做:

Promise.all(arr.map(item => {
     return saveInDatabase(item).then((myResult) => ... );
})).then(function(results) {
    // all done here
}).catch(function(err) {
    // error here
});

在其中任何一个中，如果您不希望它在拒绝时停止，则将 .catch() 添加到您的 saveInDatabase() promise 链中将拒绝变成一个已解决的 promise ，其中包含您可以检测到的一些已知值或错误值。