如何在Node.js中并行运行异步函数并即时输出结果？

核心实现思路 #

你的myFunc1是async函数（注：async函数默认会将返回值包装为Promise，哪怕你return普通值），要实现并行调用且每个结果返回后立即打印，不能用串行的await循环，而是要为每个调用单独绑定结果处理逻辑，让它们同时发起请求，各自完成后即时输出。

基础实现方案 #

直接遍历参数数组，逐个发起调用，用.then即时处理结果：

let lines = readDataFromUserProvidedFile();
// 修正循环条件：lines是数组，需用lines.length判断遍历次数
lines.forEach((line, index) => {
  myFunc1(line, index, index * 2)
    .then(result => {
      console.log(`第 ${index+1} 次调用完成，结果：`, result);
    })
    .catch(error => {
      console.error(`第 ${index+1} 次调用失败，错误：`, error);
    });
});

这个方案会同时发起所有myFunc1调用，每个调用拿到远程服务结果后立即打印，完全并行执行。

进阶：带并发限制的实现 #

考虑到单次调用耗时10分钟且是数十次并行，可能会触发远程服务的限流机制。可以用并发限制库控制同时运行的调用数量，比如p-limit：

1. 先安装依赖：

npm install p-limit

2. 实现代码：

const pLimit = require('p-limit');
// 设置同时运行的最大并发数，比如5
const limit = pLimit(5);

let lines = readDataFromUserProvidedFile();

// 用limit包装调用逻辑，控制并发
lines.forEach((line, index) => {
  limit(() => myFunc1(line, index, index * 2)
    .then(result => {
      console.log(`第 ${index+1} 次调用完成，结果：`, result);
    })
    .catch(error => {
      console.error(`第 ${index+1} 次调用失败，错误：`, error);
    })
  );
});

这个方案会在保持并行效率的同时，避免一次性发起过多请求导致服务拒绝。

补充说明 #

• async函数的特性：无论你在myFunc1里return什么值，async函数都会自动将其包装为resolved状态的Promise，所以你可以放心用.then或await处理它的返回值。
• 错误处理：一定要加上.catch捕获远程服务调用可能出现的错误（比如网络超时、服务报错），避免未处理的Promise终止程序。

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