数组中待处理Promise在for循环中无法捕获异常问题

问题根源 #

你的代码中，getAllQueues循环调用getQueue并将Promise存入数组时，这些Promise已经立即开始执行异步逻辑，而非等到matchHistoryJobFn里的await queues[i]时才启动。因此getQueue抛出的异常会在Promise创建阶段就触发，此时循环内的try/catch还未生效，导致异常逃逸无法被捕获。

修复方案 #

方案1：修改getAllQueues返回函数数组（兼顾并行/串行场景） #

让getAllQueues存储返回Promise的函数，而非直接执行Promise，确保Promise的执行时机被延迟到await阶段：

export const getAllQueues = (
  date: string,
  hour: string
) => {
  const queueFactories: (() => Promise<{
    queue: string;
    matchCount: number;
    queueDateTime: DateTime;
  }>)[] = [];
  for (const queue in QUEUE_IDS) {
    // 存储返回Promise的函数，而非直接执行
    queueFactories.push(
      () => getQueue(date, hour, queue as Queue)
    );
  }

  return queueFactories;
};

在matchHistoryJobFn中调整调用逻辑：

const queues = getAllQueues(
  dateTimeToGetQueueDate(lastMatchIdQueueDate),
  "-1"
);

let matchCount = 0;

for (let i = 0; i < queues.length; i++) {
  try {
    // 循环时才调用函数创建并执行Promise，再await
    const q = await queues[i]();
    matchCount += q.matchCount;
  } catch (e) {
    if (e instanceof GetQueueError) {
      log({
        jobId,
        jobKey,
        status: "error",
        message: e.message,
        currentDateTime: DateTime.utc().toISO(),
        meta: { queueDate: e.queueDateTime.toISO(), queue: e.queue },
      });
    } else {
      log({
        jobId,
        jobKey,
        status: "error",
        message: e as string,
        currentDateTime: DateTime.utc().toISO(),
      });
    }
  }
}

方案2：直接在循环中调用getQueue（简化场景） #

如果不需要兼顾并行调用的需求，可以去掉getAllQueues中间层，直接在循环内逐个调用并await：

let matchCount = 0;

// 直接遍历QUEUE_IDS，逐个执行并await
for (const queue in QUEUE_IDS) {
  try {
    const q = await getQueue(
      dateTimeToGetQueueDate(lastMatchIdQueueDate),
      "-1",
      queue as Queue
    );
    matchCount += q.matchCount;
  } catch (e) {
    if (e instanceof GetQueueError) {
      log({
        jobId,
        jobKey,
        status: "error",
        message: e.message,
        currentDateTime: DateTime.utc().toISO(),
        meta: { queueDate: e.queueDateTime.toISO(), queue: e.queue },
      });
    } else {
      log({
        jobId,
        jobKey,
        status: "error",
        message: e as string,
        currentDateTime: DateTime.utc().toISO(),
      });
    }
  }
}

关键原理说明 #

Promise的特性是创建即执行，当你调用getQueue时，其内部的异步逻辑已经开始运行，异常会在这个阶段抛出。只有将Promise的执行延迟到try/catch包裹的await语句时，异常才能被正确捕获。

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