如何在每次迭代中异步调用多个存在依赖关系的异步函数？

你预想的流水线调度方案是完全可以实现的，这种模式可以充分利用异步IO的等待空窗期，比全串行执行、无控制全并发执行的效率都更可控、更高。另外你给出的示例代码里有个小笔误：arrayOfParamters.map(async parameter => { ... })中调用firstFunction时传的是parameters，实际应该传当前迭代的parameter，使用时注意修正。

先明确两种常见写法的问题 #

• 直接用Promise.all(arrayOfParameters.map(...))：所有参数的firstFunction会同时触发，如果参数数量多、下游接口有并发限制，很容易触发限流报错，也会占用过多资源。
• 全串行for循环执行：必须等单个参数对应的三个异步函数全部执行完毕，才会处理下一个参数，大量时间浪费在IO等待上，效率极低。

手动实现流水线调度（无需第三方依赖） #

你可以通过简单的调度逻辑实现你要的效果：只要某个参数的firstFunction执行完毕、进入secondFunction等待阶段，就立刻启动下一个参数的firstFunction，参考代码如下：

async function pipelineProcess(arrayOfParameters, maxConcurrency = Infinity) {
  const results = new Array(arrayOfParameters.length);
  let runningCount = 0;
  let paramIndex = 0;

  return new Promise((resolve) => {
    function tryRunNext() {
      // 所有参数处理完毕且无运行中任务，返回结果
      if (paramIndex >= arrayOfParameters.length && runningCount === 0) {
        return resolve(results);
      }
      // 还有未处理参数且未到并发上限，启动新任务
      while (paramIndex < arrayOfParameters.length && runningCount < maxConcurrency) {
        const currentIdx = paramIndex++;
        runningCount++;
        // 异步执行当前参数的任务链
        (async () => {
          const firstRes = await firstFunction(arrayOfParameters[currentIdx]);
          // first执行完成，立刻尝试启动下一个参数的first，利用second的等待空窗期
          tryRunNext();
          const secondRes = await secondFunction(firstRes);
          const finalRes = await finalFunction(secondRes);
          results[currentIdx] = finalRes;
          runningCount--;
          tryRunNext();
        })();
      }
    }
    tryRunNext();
  });
}

// 调用示例：设置最大并发数为3，避免并发过高
const finalResults = await pipelineProcess(arrayOfParameters, 3);

你可以根据实际的接口限流情况调整maxConcurrency参数，平衡执行效率和并发上限。

更精简的第三方库实现 #

如果项目允许引入依赖，也可以用p-limit这类并发控制库实现相同效果，代码更简洁：

import pLimit from 'p-limit';

// 限制同时最多3个任务链执行
const limit = pLimit(3);
const finalResults = await Promise.all(
  arrayOfParameters.map(param => limit(async () => {
    const firstRes = await firstFunction(param);
    const secondRes = await secondFunction(firstRes);
    return finalFunction(secondRes);
  }))
);

注：你之前认为Promise.all无法提升效率的误区在于没有加并发控制，加上并发限制后的Promise.all完全可以实现你要的高效调度效果。

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