Node.js中如何实现监听并等待变量变化的高效方案

无需轮询，变量更新时即时触发等待逻辑，完全满足「异步等待变量变化完成」的需求。

核心思路 #

将等待变量变化的动作封装为Promise调用，变量更新时主动兑现对应Promise，彻底消除轮询开销。每次更新完成后自动生成新的待兑现Promise，支持后续持续监听。

基础实现（单变量场景） #

class WatchedVariable {
  // 内部存储实际值、待兑现的Promise、resolve方法
  #value;
  #changePromise;
  #resolveChange;

  constructor(initialValue) {
    this.#value = initialValue;
    this.#refreshPendingPromise();
  }

  // 刷新生成新的待兑现Promise，供下一次等待使用
  #refreshPendingPromise() {
    this.#changePromise = new Promise(resolve => {
      this.#resolveChange = resolve;
    });
  }

  // 同步获取当前变量值
  get current() {
    return this.#value;
  }

  // 修改变量值，触发所有等待中的异步逻辑
  set value(newVal) {
    // 值无变化时可选择不触发，不需要可以删除该判断
    if (newVal === this.#value) return;
    this.#value = newVal;
    // 兑现之前所有等待的Promise
    const prevResolve = this.#resolveChange;
    // 生成新Promise供后续等待调用
    this.#refreshPendingPromise();
    prevResolve(newVal);
  }

  // 等待变量下一次变化，返回更新后的值
  async waitForChange() {
    return this.#changePromise;
  }
}

使用示例 #

对应需求中的使用场景：

// 初始化变量，初始值为1
const variable = new WatchedVariable(1);

// 等待变量更新的异步逻辑
(async () => {
  console.log(await variable.waitForChange()); // 变量更新后立即输出 2
})();

// 修改变量的逻辑
setTimeout(() => {
  variable.value = 2;
}, 1000);

如果需要持续监听变量变化，可以直接加循环：

(async () => {
  while (true) {
    const latestVal = await variable.waitForChange();
    console.log('变量更新为：', latestVal);
  }
})();

扩展实现：监听对象任意属性变更（Proxy版本） #

如果需要监听对象的任意属性变化，可以结合Proxy封装实现：

function createWatchedObject(target) {
  let changeResolve;
  let changePromise = new Promise(r => changeResolve = r);

  const refreshPromise = () => {
    changePromise = new Promise(r => changeResolve = r);
  };

  const proxy = new Proxy(target, {
    set(obj, prop, value) {
      // 值无变化时不触发，不需要可以删除该判断
      if (obj[prop] === value) return true;
      obj[prop] = value;
      const prevResolve = changeResolve;
      refreshPromise();
      // 返回变更的属性名和新值
      prevResolve({ property: prop, newValue: value });
      return true;
    }
  });

  // 挂载等待方法
  proxy.waitForChange = () => changePromise;
  return proxy;
}

// 使用示例
const config = createWatchedObject({ port: 3000, host: 'localhost' });
(async () => {
  const changeInfo = await config.waitForChange();
  console.log(`属性${changeInfo.property}更新为${changeInfo.newValue}`);
})();
config.port = 8080;

方案优势 #

• 零轮询开销，变量更新后即时触发等待逻辑，无延迟
• 支持单次等待、持续循环监听多种使用场景
• 可以根据业务需求灵活调整：比如取消等值判断实现赋值即触发、增加超时逻辑、支持多个独立等待者等。

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