Node JS Async Promise.All 问题

Question

我正在尝试对从数据库获取的列表中的一堆项目执行异步例程，但我无法理解 promise.all 的工作原理及其作用。

这是我现在使用的代码：

/**
 * Queues up price updates
 */
function updatePrices() {

     console.log("~~~ Now updating all listing prices from Amazon API ~~~");

    //Grabs the listings from the database, this part works fine    
    fetchListings().then(function(listings) {

        //Creates an array of promises from my listing helper class 
        Promise.all(listings.map(function(listing){

            //The promise that resolves to a response from the routine
            return(listing_helper.listingPriceUpdateRoutine(listing.asin));
        })).then(function(results){

            //We want to log the result of all the routine responses
            results.map(function(result){
                console.log(result);
            });

            //Let us know everything finished
            console.log("~~~ Listings updated ~~~");
        }).catch(function(err){
            console.log("Catch: ", err);
        });
    });
}

现在，我在日志中得到的唯一信息是

~~~ 现在从 Amazon API 更新所有列表价格~~~

我尝试在被调用的例程中添加一个日志记录片段，这些例程都成功运行并记录了它们应该记录的内容，但是 promise.all.then 没有执行。

我已经尝试过：

Promise.all(bleh).then(console.log("我们做到了"));

这行得通，但是当我在 Then 中放置一个函数时，没有任何运行。

请帮忙！

Answer 1

Promise.all() 本身非常简单。你向它传递一系列承诺。它返回一个新的 Promise，当你的数组中的所有 Promise 都解决时，它会解决，或者当数组中的任何单个 Promise 被拒绝时，它会被拒绝。

var pAll = Promise.all([p1, p2, p3]);

pAll.then(function(r) {
    // all promises resolved
    // r is an array of results
}, function(err) {
    // one or more promises rejected
    // err is the reason for the first promise that rejected
});

Promise.all() 可能无法在您的代码中运行的一些原因：

1. 您没有向它传递一系列承诺。
2. 您传递的数组中的某些承诺永远不会解决或拒绝，因此 Promise.all() 永远不会解决/拒绝其主承诺
3. 您没有正确地将回调传递给您应该在的 .then() 处理程序
4. 您没有从内部函数正确返回 Promise，因此它们可以正确传播或链接

---

你的例子：

Promise.all(bleh).then(console.log("We did it"));

错了。您必须像这样将函数引用传递给.then()：

Promise.all(bleh).then(function() {
    console.log("We did it")
});

在您的情况下，console.log() 将立即执行，而不是等待承诺得到解决。

---

在您的详细代码中，您是否 100% 确定：

listing_helper.listingPriceUpdateRoutine(listing.asin)

返回一个承诺？而且，该承诺会被正确解决或拒绝吗？

---

读者须知 - 如果您阅读了所有 cmets，您会发现 OP 的实际问题不在于 Promise.all()，但由于向目标发送请求太快而受到速率限制主持人。由于这应该会传播一个应该很容易看到的请求错误，因此 OP 显然也存在错误处理或传播问题，这可能在此处未公开的代码中。