使用包含异步等待[duplicate]的数组foreach等待

Question

在node.js我需要使用一个函数ProcesMultipleCandiates（），其中包含Array.foreach处理将每个元素插入到db中，但整个函数应该在完成所有插入操作后返回响应

JavaScript代码

async function procesMultipleCandidates (data) {
  let generatedResponse = []
  await data.forEach(async (elem) => {
    try {    
          
           // here candidate data is inserted into  
           let insertResponse = await insertionInCandidate(elem) 
           //and response need to be added into final response array 
           generatedResponse.push(insertResponse)
    } catch (error) {
    console.log('error'+ error);
    }
  })
  console.log('complete all') // gets loged first
  return generatedResponse // return without waiting for process of 
}

如上所述，最后一个返回语句不等待foreach执行首先完成。

Answer 1

就我而言，for of在异步时比forEach工作得更好。无论如何，在这种情况下，如果你只关心聚合结果，我认为这可能是一个解决方案。

async function procesMultipleCandidates(data) {
  const promises = data.map(insertionInCandidate);
  return await Promise.all(promises);
}

Answer 2

数组。原型forEach（）尝试按顺序执行，您可能并不总能得到预期的结果。

数组。原型map（）广泛用于使用数据创建promise，然后使用等待promise进行解析。全部（[]）

使用. map（）函数，所有的promise都是并行解决的，如果你碰巧调用了一个应用编程接口，你可能会得到错误429：太多的请求

要按顺序执行所有promise，可以使用for。。。属于。

const array1 = ['a', 'b', 'c'];

for (const element of array1) {
  console.log(element);
}

MDN参考

Answer 3

使用Array.prototype.map和Promise.all：

js prettyprint-override">async function procesMultipleCandidates (data) {
  let generatedResponse = []
  await Promise.all(data.map(async (elem) => {
    try {
      // here candidate data is inserted into  
      let insertResponse = await insertionInCandidate(elem)  
      // and response need to be added into final response array 
      generatedResponse.push(insertResponse)
    } catch (error) {
      console.log('error'+ error);
    }
  }))
  console.log('complete all') // gets loged first
  return generatedResponse // return without waiting for process of 
}

如果不希望循环同时运行，请使用for/of循环：

async function procesMultipleCandidates (data) {
  let generatedResponse = []
  for(let elem of data) {
    try {
      // here candidate data is inserted into  
      let insertResponse = await insertionInCandidate(elem)  
      // and response need to be added into final response array 
      generatedResponse.push(insertResponse)
    } catch (error) {
      console.log('error'+ error);
    }
  }
  console.log('complete all') // gets loged first
  return generatedResponse // return without waiting for process of 
}