node.js - 简单 promise 队列 : q. 在延迟 promise 解决之前全部解决

Question

我努力完全把握 promise 的下一部分......

我正在尝试创建一个简单的 promise 队列(长期目标是限制对数据库的查询)，然后我可以将其与 Q.all() 和 Array.protoype.map() 一起使用。

(这似乎与 this question 有关，但我在那里没有看到明确的解决方案。)

这是我的简单框架:

var Q = require('q');

var queue = [];
var counter = 0;
var throttle = 2;  // i can do things at most two at a time

var addToQueue = function(data) {
    var deferred = Q.defer();
    queue.push({data: data, promise: deferred});
    processQueue();
    return(deferred.promise);
}

var processQueue = function() {
    if(queue.length > 0 && counter < throttle) {
       counter++;
       var item = queue.shift();
       setTimeout(function() {  // simulate long running async process
          console.log("Processed data item:" + item.data);
          item.promise.resolve();
          counter--;
          if(queue.length > 0 && counter < throttle) {
             processQueue(); // on to next item in queue
          }
       }, 1000);
    }
}

data = [1,2,3,4,5];
Q.all(data.map(addToQueue))
    .then(console.log("Why did get here before promises all fulfilled?"))
    .done(function() {
        console.log("Now we are really done with all the promises.");
    });

但是，正如上面所暗示的，“then”会立即被调用，只有“done”会被推迟到所有 promise 都得到解决。我注意到 api documentation唯一的例子确实使用了 .done() 而不是 then()。所以也许这是预期的行为？问题是我无法链接其他操作。在这种情况下，我需要创建另一个延迟 promise 并在 Q.all 的 done 函数中解决它，如下所示

data = [1,2,3,4,5];

var deferred = Q.defer();

deferred.promise
    .then(function() {
        console.log("All data processed and chained function called.");
    })  // could chain additional actions here as needed.

Q.all(data.map(addToQueue))
    .done(function() {
        console.log("Now we are really done with all the promises.");
        deferred.resolve();
    });

这按预期工作，但额外的步骤让我觉得我一定遗漏了一些关于如何正确使用 Q.all() 的东西。

我对 Q.all() 的使用有问题吗，或者上面的额外步骤实际上是正确的方法吗？

编辑:

Tyrsius 指出我对 .then 的论点不是对函数的引用，而是一个立即计算函数 (console.log(...))。这是我应该如何做到的:

Q.all(data.map(addToQueue))
    .then(function() { console.log("Ahhh...deferred execution as expected.")})

Answer 1

实际上，您的问题出在标准 Javascript 上。

Q.all(data.map(addToQueue))
    .then(console.log("Why did get here before promises all fulfilled?"))
    .done(function() {
        console.log("Now we are really done with all the promises.");
    });

仔细看第二行。 Console.log 被立即评估并作为参数发送到 .then。这与 promise 无关，它只是 javascript 如何解析函数调用。你需要这个

Q.all(data.map(addToQueue))
        .then(function() { console.log("Why did get here before promises all fulfilled?")})
        .done(function() {
            console.log("Now we are really done with all the promises.");
        });

---

编辑

如果这是你经常做的事情，你可以制作一个按你想要的方式工作的函数返回函数

function log(data) {
    return function() { console.log(data);}
}

Q.all(data.map(addToQueue))
        .then(log("Why did get here before promises all fulfilled?"))
        .done(function() {
            console.log("Now we are really done with all the promises.");
        });