使用await结合forEach调用Promise封装的异步服务未按预期同步执行的问题排查

你对 await 的理解是对的——它会暂停当前异步函数的执行，直到Promise状态改变，但问题出在 forEach 并不会等待传入的异步回调函数完成。

让我们拆解一下你的代码执行流程：

1. 打印 start
2. 进入 instances.forEach(async (instance) => {...})：
   • forEach会同步遍历整个数组，每遇到一个instance，就立刻调用你传入的async函数
   • 每个async函数里，先打印 request sent，然后遇到 await collectMetrics(instance)——这会暂停当前这个async函数的执行，把Promise放到后台处理，但forEach不会等这个async函数执行完，直接跳到下一个instance，继续触发下一个async函数
3. 四个async函数都被触发后，forEach执行完毕，立刻打印 finish
4. 之后四个异步请求陆续完成，各自的async函数从暂停处恢复，打印 data received

这就是为什么你会看到先一次性输出所有request sent和finish，最后才收到data received的原因。

解决方案1：需要顺序执行（逐个发送请求） #

如果你的需求是等待上一个请求完成后再发送下一个，用for...of循环代替forEach就可以解决问题——for...of支持在循环体中使用await，会等待当前异步操作完成后再进入下一次循环：

console.warn('start');
// 用for...of替代forEach
for (const instance of instances) {
  console.log('request sent');
  const metrics = await collectMetrics(instance);
  console.log('data received', metrics);
}
console.warn('finish');

这样执行顺序就会和你预期的一致：

start
request sent
data received [结果]
request sent
data received [结果]
...
finish

解决方案2：不需要顺序，但要等所有请求完成后再打印finish #

如果你的需求是同时发送所有请求（提高效率），但希望所有请求都完成后再打印finish，可以用Promise.all来收集所有请求的Promise，等待全部完成：

console.warn('start');
// 收集所有请求的Promise
const requestPromises = instances.map(async (instance) => {
  console.log('request sent');
  const metrics = await collectMetrics(instance);
  console.log('data received', metrics);
  return metrics;
});
// 等待所有Promise完成
await Promise.all(requestPromises);
console.warn('finish');

这里的执行顺序会是：

start
request sent
request sent
request sent
request sent
data received [结果]
data received [结果]
data received [结果]
data received [结果]
finish

这种方式既保持了并发请求的效率，又能确保所有请求完成后再执行后续逻辑。

内容的提问来源于stack exchange，提问作者Molly Birk