Node.js中如何实现非阻塞回调函数同步等待 解决async/await误用问题

核心问题原因 #

你之前的 async/await 写法不生效，是因为 obj.connect 属于回调风格的异步函数，本身不会返回 Promise 实例，而 await 关键字只能对 Promise 类型生效，所以才会出现异步任务还没完成，代码就直接往下执行的情况。
Node.js 本身的执行模型和 C 语言多线程模型不同，不存在完全等价的线程阻塞式 join 方法，但可以通过回调转 Promise的方式实现非阻塞式的等待，效果上和你需要的“等异步执行完再往下走”的逻辑完全一致，且这个方案对所有符合 Node.js 标准回调规范的非阻塞库函数都通用。

具体实现方案 #

方案1：手动封装 Promise（无依赖，全场景适用） #

直接把回调逻辑包裹在 Promise 实例中，成功时调用 resolve 传递结果，错误时传递空值或者抛出错误：

function make_connection() {
  // 返回Promise实例，外部可直接await
  return new Promise((resolve) => {
    const obj = some_kind_of_obj_used_for_connection;
    // 此处省略obj连接前的准备逻辑
    
    obj.connect(err => {
      if(err) {
        // 错误场景返回null，和你的原有逻辑对齐
        resolve(null);
        return;
      }
      // 连接成功返回连接对象
      resolve(obj);
    })
  })
}

方案2：使用 Node.js 内置工具简化转换 #

如果回调函数符合 Node.js 标准约定（回调第一个参数为错误对象，后续参数为返回结果），可以用 util.promisify 直接把回调函数转为返回 Promise 的函数，省略手动封装的重复代码：

// 引入Node.js内置的转换工具
const { promisify } = require('util');

async function make_connection() {
  const obj = some_kind_of_obj_used_for_connection;
  // 转换connect方法，绑定this指向避免执行上下文错误
  const connect = promisify(obj.connect).bind(obj);
  
  try {
    await connect();
    return obj;
  } catch(err) {
    // 错误处理，返回null
    return null;
  }
}

调用方式 #

注意 await 关键字需要放在异步函数调用的前面，不能写在变量声明关键字之前：

async function test() {
  // 等待连接完成，再往下执行后续逻辑
  const returned_connection = await make_connection();
  if(returned_connection) {
    // 此处可以正常使用已建立完成的连接
  }
  return 0;
}

// 顶层调用需要用立即执行async函数包裹（Node.js 14.8+支持顶层await）
(async () => {
  await test();
})();

注意事项 #

不要尝试用强制同步阻塞的方式实现该需求，Node.js 是单线程事件循环模型，同步阻塞会卡住整个进程的所有任务，上述非阻塞等待方案是 Node.js 生态的标准实现，只会暂停当前 async 函数的执行，不会影响其他任务的运行。

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