Promise结合forEach无法等待循环完成问题求助

你的核心问题是手动管理Promise完成状态的逻辑不可靠，应该用Promise.all来批量处理异步操作，它会等待所有Promise都完成后再执行后续逻辑，同时还能统一处理成功和失败的情况。

步骤1：重构create方法（可选但更规范） #

你的create方法里把Observable转成Promise的写法可以简化，直接用RxJS的firstValueFrom替代手动创建Promise，代码更简洁可靠：

import { firstValueFrom } from 'rxjs';

create(anObject: any, anOtherObject: myAnotherObject): Promise<AnotherObjectAgain | null> {
  return firstValueFrom(this.AService(anObject.file, anOtherObject.id)).then(result2 => {
    if (result2) {
      const returnObj = new AnotherObjectAgain();
      returnObj.date = result2.body;
      return returnObj;
    } else {
      this.alertService.error('error.internalServer');
      return null;
    }
  }).catch(err => {
    this.alertService.error('error.transmission');
    throw err; // 保留错误，让Promise.all统一捕获
  });
}

步骤2：重构主逻辑，用Promise.all替代手动判断 #

原来手动判断数组长度的方式容易出现逻辑漏洞，改用Promise.all收集所有异步操作的Promise，等全部完成后再构建目标数组：

// 初始化目标数组
const promiseArray: MyObject[] = [];

// 遍历myarray，收集所有create操作的Promise
const asyncTasks = myarray.map(itemArray => {
  return this.create(anObject, anOtherObject).then(result => {
    // 每个异步操作完成后，构建MyObject实例并返回
    return new MyObject(itemArray.file.name, itemArray.type, itemArray.ordre, result?.urlFichier);
  });
});

// 等待所有异步任务完成后执行后续逻辑
Promise.all(asyncTasks).then(results => {
  // 将所有结果批量存入promiseArray
  promiseArray.push(...results);
  // 执行你的后续代码
  // .. Other Code
}).catch(err => {
  // 统一处理所有异步任务的错误
  this.alertService.error('error.transmission');
});

原写法的问题分析 #

1. 逻辑不可靠：如果某个create操作失败，不会向promiseArray中添加元素，导致promiseArray.length永远无法等于myarray.length，resolve永远不会触发；反之如果出现意外的长度相等（比如第一个任务完成时刚好数组长度匹配），会提前执行后续代码。
2. 错误处理分散：单个create的错误不会终止整个流程，也无法通知主Promise的错误回调，容易遗漏异常情况。
3. Promise.resolve重复调用：虽然Promise的resolve只会生效一次，但多次调用属于冗余逻辑，隐藏潜在漏洞。

Promise.all的优势 #

• 自动等待所有任务：确保所有异步操作完成后才执行后续代码，不会提前触发。
• 结果顺序一致：返回的结果数组顺序和原myarray完全对应，保证数据顺序正确。
• 统一错误处理：只要有一个异步任务失败，会立刻进入catch回调，便于集中处理异常。

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