在async.parallel中使用async/await时callback未定义问题求助

这个问题我之前也碰到过！核心原因是**async.parallel 是传统的回调式异步控制工具，它无法自动识别async函数返回的Promise**，再加上你没有在async函数内部手动调用它期望的callback，所以才会出现「去掉async/await就正常，加上就无法触发callback」的情况。

具体原因拆解 #

当你把任务写成async function(callback)时，这个函数本质上会自动返回一个Promise，但async.parallel的设计逻辑是通过你手动调用传入的callback参数来判断任务是否完成，它并不会等待async函数的Promise状态变更。如果你的代码里只做了await操作但没调用callback，async.parallel就会一直处于等待状态，永远不会触发最终的汇总回调。

两种可行的解决方案 #

方案一：在async函数内手动调用callback #

如果你想继续使用async.parallel，只需要在await操作完成后，手动调用callback来通知async.parallel任务完成（成功时传null+结果，失败时传错误对象）：

let parallelFunc = listCamId.map(camId => {
  return async function (callback) {
    let insertRuleTransParam = {
      "rule_id": ruleId,
      "camera_id": camId,
      "vas_id": vasId,
      "additional_parameter": additionalParameter
    }
    let configParamCamera = { "where": { "id": camId } };
    let configParamRule = { "where": { "id": ruleId } };
    try {
      let ruleTrans = await createRuleTransact(insertRuleTransParam);
      // 这里可以添加其他await操作
      
      // 任务成功完成，调用callback通知async.parallel
      callback(null, ruleTrans);
    } catch (err) {
      // 任务出错，将错误传入callback
      callback(err);
    }
  };
});

// 调用async.parallel
async.parallel(parallelFunc, function(err, results) {
  if (err) {
    console.error("并行任务出错:", err);
    return;
  }
  console.log("所有任务结果:", results);
});

方案二：改用原生Promise.all替代async.parallel（更推荐） #

既然你已经在使用async/await（它本身就是Promise的语法糖），其实完全没必要依赖async.js的工具，原生的Promise.all就可以完美实现并行异步任务的控制，代码更简洁也更符合现代JS的写法：

// 把每个任务写成返回Promise的async函数（不需要callback）
let promiseTasks = listCamId.map(async camId => {
  let insertRuleTransParam = {
    "rule_id": ruleId,
    "camera_id": camId,
    "vas_id": vasId,
    "additional_parameter": additionalParameter
  }
  let configParamCamera = { "where": { "id": camId } };
  let configParamRule = { "where": { "id": ruleId } };
  
  let ruleTrans = await createRuleTransact(insertRuleTransParam);
  // 这里可以添加其他await操作
  
  return ruleTrans; // 返回的结果会被Promise.all收集
});

// 用Promise.all并行执行所有任务
try {
  let results = await Promise.all(promiseTasks);
  console.log("所有任务结果:", results);
} catch (err) {
  console.error("并行任务出错:", err);
}

这个方案的优势是：不需要额外依赖第三方库，语法更统一，而且Promise.all会自动等待所有任务完成，任何一个任务出错都会立即触发catch逻辑，和async/await的配合更顺畅。

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