Promise all 中的同步循环

Question

我想在我的部分代码中做一个同步循环。 函数 saveInDatabase 检查数据库中是否已存在项目标题（字符串）。这就是为什么它不能并行解决，否则条件永远不会适用（并且会产生重复）。

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

我尝试将这个函数封装到单独的promise中，也尝试使用npm包（synchronous.js，sync），但它似乎不适合我的代码。

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

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

Answer 1

不使用await（不在node.js v6.11.2 中，但会使这更简单），序列化一堆返回承诺的异步操作的经典模式是使用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() 来将拒绝的承诺变成一个履行的承诺。

---

在 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() 承诺链中，以将拒绝变成具有某些已知值或错误值的已解决承诺可以检测到。