时间戳

首页 > 解决方案 > 按顺序执行promises map

javascript - 按顺序执行promises map

问题描述

我编写了一个在循环（映射）中调用的函数，并且该函数正在使用 Promise。现在，我希望该函数在调用下一个实例之前同步运行并退出。

function t1(){
  let arr1 = [1,2,3,4,5];
  return Promise.map(arr1, (val) =>{
    const params = {
      "param1" : val1
    };
    return t2(params);
  });
}

function t2(event){
  return Promise.resolve()
  .then({
  //do something
  //code doesn't reach here in sync manner. all five instance are invoked and then code reaches here for first instance and so on
  })
  .then({
  //promise chaining. do something more
  })
}

t2 被调用五次，但我希望每个实例仅在实例返回值之前被调用。目前它的行为不是那样，而是并行调用该函数五次。

由于项目限制，我无法使用 async/await。

标签： javascriptnode.jspromise

解决方案

您当前代码的问题在于Promise.prototype.map，像 一样forEach，不会等待在其中调用的异步函数完成。await（除非您使用or明确地告诉解释器这样做，否则不会等待任何异步调用.then）

等待t1每次调用t2：

async function t1(){
  let arr1 = [1,2,3,4,5];
  const results = [];
  for (const val of arr1) {
    results.push(await t2(val));
  }
  return results;
}

或者，如果您想使用reduce而不是async/ await：

const delay = () => new Promise(res => setTimeout(res, 500));
function t1(){
  let arr1 = [1,2,3,4,5];
  return arr1.reduce((lastProm, val) => lastProm.then(
    (resultArrSoFar) => t2(val)
      .then(result => [...resultArrSoFar, result])
  ), Promise.resolve([]));
}

function t2(event){
  return delay().then(() => {
    console.log('iter');
    return event;
  });
}

t1()
  .then(results => console.log('end t1', results));

或者，如果您需要将顺序功能封装在 t2 中，则让 t2 具有它生成的前一个 Promise 的半持久变量：

const delay = () => new Promise(res => setTimeout(res, 500));
const t1 = () => {
  return Promise.all([1, 2, 3, 4].map(t2));
};

const t2 = (() => {
  let lastProm = Promise.resolve();
  return (event) => {
    const nextProm = lastProm
      .catch(() => null) // you may or may not want to catch here
      .then(() => {
        // do something with event
        console.log('processing event');
        return delay().then(() => event);
      });
    lastProm = nextProm;
    return nextProm;
  };
})();

t1().then(results => console.log('t1 done', results));

推荐阅读