1

我在我的代码中执行多个批处理异步操作。尽管批处理中的操作应该异步执行，但批处理应该一个接一个地同步执行。

这是我创建的一个jsfiddle 。查看控制台，因为所有输出都在那里。为了方便起见，这里是代码：

asyncChain(10, 'FIRST CHAIN')
.then(function () {
  asyncChain(10, 'SECOND CHAIN');
})
.then(function(){
  asyncChain(10, 'THIRD CHAIN');
});

function asyncChain(n, msg) {
  var promiseChain = Q.fcall(function () {
    10;
  });
  console.log('starting:' + msg);
  for (var i = 0; i < n; i++) {
    promiseChain = promiseChain.then(asyncOperation(i, msg));
  }
  console.log('returning' + msg);
  return promiseChain;
}

function asyncOperation(i, msg) {
  var d = Q.defer();

  setTimeout(function () {
    console.log('resolving for #' + i + msg);
    d.resolve(i);
  }, 300 + Math.random()*1000);

  return d.promise;
}

基本上这些是我希望一个接一个完成的 3 批承诺操作。这意味着此示例的输出将如下所示：

starting FIRST CHAIN
returning FIRST CHAIN
resolving 1..10 FIRST CHAIN

starting SECOND CHAIN
returning SECOND CHAIN
resolving 1..10 SECOND CHAIN
and so on

我尝试使用all()方法而不是，then()但它在第一个链后停止执行。我错过了一些明显的东西吗？

感谢您的任何建议。

干杯

4

1 回答 1

6

我错过了一些明显的东西吗？

是的。为了then用另一个 Promise 解决这个 Promise，你必须将另一个 Promise返回给它。您的函数只是启动另一个asyncChain，但从undefined立即解决承诺的回调返回。

asyncChain(10, 'FIRST CHAIN').then(function () {
  return asyncChain(10, 'SECOND CHAIN');
}).then(function(){
  return asyncChain(10, 'THIRD CHAIN');
});
于 2013-09-23T06:16:17.410 回答