一个接一个地执行一系列 Javascript 承诺

Question

我想知道是否有一种方法可以瀑布式执行一系列承诺？即我希望下一个承诺在当前承诺得到解决之前不开始。

我的测试：

import Promise from 'bluebird'

describe('promises waterfall', () => {
  const result = []
  function doItLater(val, time = 50) => {
    return new Promise(resolve => {
      setTimeout(() => {
        result.push(val)
        resolve(val)
      }, time)
    })
  }

  it('execute promises one after one resolved', done => {
    result.push(1)
    const promiseList = [doItLater('a', 100),doItLater('b', 1),doItLater('c')]
    result.push(2)

    Promise.each(
      promiseList,
      (output) => {
        result.push(output + '-outputted')
      }
    )
      .then(
        () => {
          result.push(3)
          console.log(result)
          expect(result).to.eql([ 1, 2, 'a', 'b', 'c', 'a-outputted', 'b-outputted', 'c-outputted', 3 ])
          done()
        }
      )
  })
})

更新

抱歉，如果我说得太混乱了。我在问我怎样才能让我的考试通过。目前我的测试失败了 - 实际结果顺序错误：

[ 1,
  2,
  'b',
  'c',
  'a',
  'a-outputted',
  'b-outputted',
  'c-outputted',
  3 ]

Answer 1

当你像这样创建承诺时

[doItLater('a', 100),doItLater('b', 1),doItLater('c')]

它们已经在异步执行。无法控制它们的执行顺序。

您可以使用 Promise.reduce 来处理您的情况，像这样

Promise.reduce([['a', 100], ['b', 1], ['c']], function(res, args) {
    return doItLater.apply(null, args).then(function(output) {
        res.push(output + '-outputted');
        return res;
    });
}, result)
.then(function(accumulatedResult) {
    ....
});

现在，我们正在一个接一个地创建 promise，在之前的 promise 被 resolve 之后，我们将结果累加到 res（实际上是 result）。解决所有承诺后，accumulatedResult 将具有所有值。

注意：强烈建议不要在函数之间共享数据。如果必须这样做，请确保您有充分的理由这样做。

Answer 2

// Promisse waterfall pattern
var promises = [1,2,3].map((guid)=>{
    return (param)=> {
      console.log("param", param);
      var id = guid;
      return new Promise(resolve => {
        // resolve in a random amount of time
        setTimeout(function () {
          resolve(id);
        }, (Math.random() * 1.5 | 0) * 1000);
      });
    }
}).reduce(function (acc, curr, index) {
  return acc.then(function (res) {
    return curr(res[index-1]).then(function (result) {
      console.log("result", result);
      res.push(result);
      return res;
    });
  });
}, Promise.resolve([]));
promises.then(console.log);

一个接一个地执行一系列 Javascript 承诺

Execute an array of Javascript promises one after one resolved

javascript

reduce

asynchronous

promise

bluebird