等待异步调用完成并返回

Question

我需要在 nodejs 中编写一些云函数。这个特定的 Cloud Function 需要遍历 URL 数组并对第三方 API 进行一些异步调用。

这是一些模拟我正在尝试做的占位符代码，改编自here：

function checkPhotos(photos) {
  var checkedPhotos = [];
  var promiseArray = photos.map(asyncFunction);

  Promise.all(promiseArray).then(results => {
    console.log('results are: ', results)
    results.forEach(result => { checkedPhotos.push(result) });
  })

  // I want to block here until the Promise.all call above completes
  // but it does not block, it returns [] immediately while the async
  // calls run
  return checkedPhotos;
}

// This is a pretend async function to simulate the third party API
function asyncFunction(photo) {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      console.log("in async function, photo is " + photo)
      resolve(photo)
    }, Math.random()*2000)
  })
}

然后我调用函数：

var photos = ['https://example.com/example.jpg', 'https://example.com/example2.jpg'];
var checkedPhotos = checkPhotos(photos);

我希望checkedPhotos 包含来自results 的值，但起初它是一个空数组，然后异步调用完成并填充数组。如何使 checkPhotos() 阻塞，直到所有异步调用都完成，以便我可以将 checkedPhotos 作为完全填充的数组返回？

Answer 1

我建议只返回Promise.all，因为你没有在函数内部做任何事情。如果您想执行任何操作，请使用 async/await 等待结果。

async function checkPhotos(photos) {
    var checkedPhotos = [];
    var promiseArray = photos.map(asyncFunction);

    const results = await Promise.all(promiseArray);
    console.log('results are: ', results)
    results.forEach(result => { checkedPhotos.push(result) });
    // Some other action
    return checkedPhotos;
}

没有动作

function checkPhotos(photos) {
  var promiseArray = photos.map(asyncFunction);
  return Promise.all(promiseArray);
}

async function somefunc(){
    await checkPhotos(photos);
} 

Answer 2

在您的示例中，您必须在 Promise.all 回调函数中返回值，因为 Promise.all 将订阅该异步调用并要求数据库引擎在完成后运行回调函数。此外，您还需要订阅Promise.all.the(cb).catch(cb) 中的 catch 函数并传递回调函数 Incas 的错误也会返回一些内容。

另一种等待所有承诺完成的方法，你必须使用 async 和 await 关键字，只需在 function checkPhotos(... 之前添加 async 关键字和在 Promise.all... 之前添加广告 await 关键字，这将告诉 js 引擎当您收到响应时，您需要在等待行下面运行代码。

如果您从另一个函数调用此函数，则需要其他函数来等待解决此问题，您可以简单地使用上层异步等待解决方案并在调用时订阅此函数回调，如下所示。

 function other () {
  checkPhotos(photos).then(cb);
 }

   async function checkPhotos(photos) {
     .....
      await Promise.all(....then()..)
         // Do some stuff
        return checkedPhotos
       }

这就是 js 处理异步调用的方式，它不会阻塞你的代码（事件循环），它只是允许你订阅一个异步调用并传递一个回调函数，以便在 JavaScript 得到响应后执行。

Answer 3

为什么不使用异步等待？

async function checkPhotos(photos) {
  var checkedPhotos = [];

  for (const photo of photos) {
    let result = await asyncFunction(photo);
    checkedPhotos.push(result);
  }

  return checkedPhotos;
}

然后这样称呼它：

var photos = ['https://example.com/example.jpg', 'https://example.com/example2.jpg'];
checkPhotos(photos)
.then(checkedPhotos => {
  // do something
})