如何在循环和承诺函数中等待承诺

Question

我正在尝试在循环中等待多个承诺。此循环必须转 3 次发送 3 个产品数组。两个初始循环将分别发送 1000 个产品，第三个循环将发送 500 个。

事实是该函数忽略了第三轮而不是将其发送到数据库，正如您在该日志中看到的那样，仅添加了 2000 个产品

我的方法

const MAXIMUM_POST_SIZE = 1000
export const addProducts = (products) => new Promise(
  (resolve, reject) => {
    for (let i = 0; i < Math.ceil(products.length / MAXIMUM_POST_SIZE); i += 1) {
      const indexToStartExtraction = i * MAXIMUM_POST_SIZE;
      const sizeOfExtraction = indexToStartExtraction + MAXIMUM_POST_SIZE;
      const extractedProducts = products.slice(indexToStartExtraction, sizeOfExtraction);
      const ref = firebase.ref('products');
      const normalizedPostData = arrayToJsonObjectWithUid({ products: extractedProducts, ref });

      console.log(extractedProducts.length);

      ref.update(normalizedPostData).then(() => {
        console.log(`Doing ${i} call`);
        resolve(true);
      })
        .catch((err) => reject(err));
    }
  },
);

我试过没有成功：

export const addProducts = (products) => new Promise(
  (resolve, reject) => {
    const promises = [];

    for (let i = 0; i < Math.ceil(products.length / MAXIMUM_POST_SIZE); i += 1) {
      const indexToStartExtraction = i * MAXIMUM_POST_SIZE;
      const sizeOfExtraction = indexToStartExtraction + MAXIMUM_POST_SIZE;
      const extractedProducts = products.slice(indexToStartExtraction, sizeOfExtraction);
      const ref = firebase.ref('products');
      const normalizedPostData = arrayToJsonObjectWithUid({ products: extractedProducts, ref });

      console.log(extractedProducts.length);

      promises.push(ref.update(normalizedPostData));
    }
    Promise.all(promises)
      .then(() => resolve())
      .catch(() => reject());
  },
);

如何正确等待每个承诺？

Answer 1

我的理解是您希望串联运行它们。您当前使用 Promise.all 的代码将并行运行它们。

如果您想连续运行它们，最简单的方法（因为您使用的是 Node.js）是使用 async 函数和 await：

const MAXIMUM_POST_SIZE = 1000
export const addProducts = async (products) => {
  for (let i = 0; i < Math.ceil(products.length / MAXIMUM_POST_SIZE); i += 1) {
    const indexToStartExtraction = i * MAXIMUM_POST_SIZE;
    const sizeOfExtraction = indexToStartExtraction + MAXIMUM_POST_SIZE;
    const extractedProducts = products.slice(indexToStartExtraction, sizeOfExtraction);
    const ref = firebase.ref('products');
    const normalizedPostData = arrayToJsonObjectWithUid({ products: extractedProducts, ref });

    console.log(extractedProducts.length);

    console.log(`Doing ${i} call`);
    await ref.update(normalizedPostData);
  }
  return true;
};

任何最新版本的 Node.js 都支持 async 函数。

该函数返回一个承诺：

• 如果任何ref.update 呼叫被拒绝，则拒绝，或者
• 当所有这些都成功完成时，使用值 true 完成

在开始下一个之前，它会等待每个完成。相比之下，您的带有Promise.all 的版本会启动所有更新，让这些更新同时运行，然后等待它们全部完成。

请注意，调用 addProducts 的任何内容都需要等待其承诺完成，除非 addProducts 调用之后的任何内容可以与更新调用 addProducts 开始同时运行。

Answer 2

我认为您不应该使用await，因为所有请求都是相互独立的，并且可以并行运行，因此您的第二个示例应该是最好的路线。

这是一个简单的 for 循环进行异步操作的 sn-p：

function someAsyncFn (i) {
  return new Promise ((resolve) => setTimeout(() => {
    console.log(i)
  }, 100))
}

const promises = []
for (let i=0; i<5; i++) {
  promises.push(someAsyncFn(i))
}

Promise.all(promises)

注意它在执行后如何产生正确的值

现在我们想要同样的东西，但应用到您的代码库：

function addProducts (products) {
  return new Promise(
    (resolve, reject) => {
      const promises = [];
      const ref = firebase.ref('products');
      const max = Math.ceil(products.length / MAXIMUM_POST_SIZE)

      for (let i = 0; i < max; i++) {
        const indexToStartExtraction = i * MAXIMUM_POST_SIZE;
        const sizeOfExtraction = indexToStartExtraction + MAXIMUM_POST_SIZE;
        const extractedProducts = products.slice(indexToStartExtraction, sizeOfExtraction);
        const normalizedPostData = arrayToJsonObjectWithUid({ products: extractedProducts, ref });
        promises.push(ref.update(normalizedPostData));
      }

      Promise.all(promises)
        .then(resolve)
        .catch(reject);
    },
  );
}

我做了一些清理，但想法是一样的，你可以试试这个代码，看看它是否产生了正确的结果？