尝试并行调用带不同参数的同一函数失败，Promise.all与Bluebird均串行执行

你遇到的这个问题大概率是因为prepareFileContent函数本身是同步执行的——JavaScript是单线程的，同步任务会被依次执行，哪怕用了Promise.all或者Bluebird.map，也没办法让同步代码并行起来。

先看看你的代码片段：

let records = await getRecords(query);
if (_.size(records) > 0) {
bluebird.map(records, function (record) {
return prepareFileContent(record.MESSAGE_PAYLOAD);
}, { concurrency: records.length }).then(function (data)...

这里的关键卡点就在prepareFileContent的实现逻辑上：如果它是纯同步的（比如只是内存里的字符串处理、数据计算，没有异步IO/网络请求这类非阻塞操作），那Bluebird.map会被迫逐个执行它——因为同步代码会阻塞事件循环，根本没机会同时跑多个任务。

具体解决步骤 #

1. 把prepareFileContent改成异步函数 #

把同步逻辑包装成Promise，并且把核心处理逻辑放到异步队列里（比如Node.js里的setImmediate/process.nextTick，或者通用的setTimeout），这样事件循环就能同时调度多个任务了：

function prepareFileContent(payload) {
  return new Promise((resolve) => {
    // 把同步逻辑丢到异步队列，让出事件循环
    setImmediate(() => {
      // 原来的同步处理代码
      const processedContent = /* 你的数据处理逻辑 */;
      resolve(processedContent);
    });
  });
}

如果prepareFileContent里本来就有异步操作（比如读文件、调用外部API），那一定要确保它正确返回Promise。比如原来用回调的写法，要改成Promise包装：

function prepareFileContent(payload) {
  return new Promise((resolve, reject) => {
    fs.readFile(payload.filePath, (err, rawData) => {
      if (err) return reject(err);
      // 处理读取到的原始数据
      const content = formatData(rawData);
      resolve(content);
    });
  });
}

2. 验证并发效果 #

可以在prepareFileContent里加日志，直观判断是不是真的并行：

function prepareFileContent(payload) {
  return new Promise((resolve) => {
    console.log(`开始处理: ${payload.id}`);
    setImmediate(() => {
      console.log(`完成处理: ${payload.id}`);
      resolve(/* 处理结果 */);
    });
  });
}

如果日志是批量输出“开始处理”，再批量输出“完成处理”，那就是并行的；如果是“开始→完成→开始→完成”的串行顺序，说明函数还是同步的，得再检查包装逻辑。

3. 原生Promise.all的写法（如果不用Bluebird） #

如果你想用原生API实现并行，逻辑和Bluebird一致，核心还是保证每个任务是异步的：

if (_.size(records) > 0) {
  const taskPromises = records.map(record => 
    prepareFileContent(record.MESSAGE_PAYLOAD)
  );
  const data = await Promise.all(taskPromises);
  // 处理最终返回的data数组
}

总结 #

JavaScript的“并行”只能针对异步任务——同步任务因为单线程的特性，永远没法真正并行执行。所以解决问题的核心就是把你的处理函数改成异步返回Promise的形式，让事件循环有机会同时调度多个任务。

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