Async/Await在for循环中失效，如何串行处理批量数据？

哈哈，我太懂这种踩坑的感觉了！你遇到的问题十有八九是没把异步批次的串行逻辑写对——很多人刚开始写异步批量处理时，容易掉进forEach/map这类数组方法的坑里，导致所有批次的请求同时触发，完全没做到预期的串行执行。

先说说你可能踩的坑 #

我猜你的sendInBatches函数大概是这么写的：

// 错误示例：用forEach处理异步，无法串行
async function sendInBatches(batches) {
  batches.forEach(async (batch) => {
    await asyncMethod(batch);
    console.log(`批次处理完成: ${JSON.stringify(batch)}`);
  });
}

// 你的asyncMethod（按描述修改成接收参数的版本）
function asyncMethod(batch) {
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`处理批次: ${JSON.stringify(batch)}`);
      resolve();
    }, 1000);
  });
}

为什么这个写法不对？因为forEach根本不会等待回调里的await完成——它会一口气把所有异步任务都启动，所以你会看到所有批次几乎同时开始处理，1秒后一起输出结果，完全不符合串行的预期。

正确的串行实现方式 #

方法1：用for...of循环（最直观）

这是最容易理解和维护的写法，for...of会等待每次循环里的异步操作完成后，再进入下一次循环：

async function sendInBatches(batches) {
  for (const batch of batches) {
    await asyncMethod(batch);
    console.log(`批次处理完成: ${JSON.stringify(batch)}`);
  }
}

// 测试调用
sendInBatches([[1,2], [3,4], [5,6]]);

运行后你会看到每1秒处理一个批次，输出顺序和输入的批次顺序完全一致，完美实现串行。

方法2：用reduce构建Promise链

如果你更喜欢函数式写法，可以用reduce来累积一个Promise链，确保上一个批次处理完再执行下一个：

async function sendInBatches(batches) {
  return batches.reduce(async (prevTask, batch) => {
    // 先等上一个批次的任务完成
    await prevTask;
    // 再执行当前批次的异步操作
    await asyncMethod(batch);
    console.log(`批次处理完成: ${JSON.stringify(batch)}`);
  }, Promise.resolve()); // 初始值是一个已resolved的Promise
}

这个原理是每次迭代都返回一个新的Promise，链接着上一个任务的完成状态，同样能实现串行处理。

关键总结 #

要实现异步串行，核心是确保每一个批次的异步操作完成后，再启动下一个。forEach、map这类数组方法不支持等待异步回调，所以绝对不能用来做串行异步处理。而for...of或者reduce是最常用且可靠的两种方式。

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