等待异步函数的 while 循环 (Node.js/ES6)

Question

我正在编写一个 Windows Node.js 服务器应用程序（使用 ES6 顺便说一句）。

我想做的第一件事 - 在顶级代码中 - 是坐在一个 while 循环中，调用一个搜索特定注册表键/值的异步函数。此函数已被“证明” - 如果找到，则返回值数据，否则抛出：

async GetRegValue(): Promise<string> { ... }

我需要坐在一个while循环中，直到注册表项存在，然后获取值数据。 （重试之间有延迟）。 我想我知道如何等待异步调用完成（一种或另一种方式），然后再进行其余的启动，但我不知道如何坐在循环中等待它 成功。

请就如何实现这一目标提供任何建议？ （我对 typescript 还很陌生，仍然难以理解所有异步/等待场景！）

谢谢

编辑

谢谢各位。我知道我对我的代码“含糊不清”——我不想尝试我的真实/伪代码，因为它们可能都忽略了你希望能帮助我理解的要点。 所以我只是将其保留为文字描述......不过我会尝试：

async GetRegValue(): Promise<string> {

    const val: RegistryItem = await this.GetKeyValue(this.KEY_SW, this.VAL_CONN);
    return val.value
}

private async GetKeyValue(key: string, name: string): Promise<RegistryItem> {

    return await new Promise((resolve, reject) => {
        new this.Registry({
            hive: this.Hive, key
        }).get(name, (err, items) => {

            if (err) {
                reject(new Error('Registry get failed'));
            }
            else {
                resolve( items );
            }
        });
    })
        .catch(err => { throw err });
}

所以我想做这样的事情：

let keyObtained = false
let val
while (keyObtained == false)
{
    // Call GetRegValue until val returned, in which case break from loop
    // If exception then pause (e.g. ~100ms), then loop again
    }
}

// Don't execute here till while loop has exited

// Then use 'val' for the subsequent statements

正如我所说，GetRegValue() 在我使用它的其他地方工作正常，但在这里我试图暂停进一步执行（并重试），直到它返回一个值

Answer 1

您可能只使用递归。下面是一个示例，说明如何继续调用 GetRegValue 函数，直到使用下面的 retryReg 函数解析。

如果遇到 catch 案例，它将一遍又一遍地调用GetRegValue，直到成功解决。

你应该在 catch() 中添加一个计数器，如果你尝试了 x 次你就放弃了。

请记住，我模拟了整个 GetRegValue 函数，但鉴于你所说的，这仍然对你有用。

let test = 0;

function GetRegValue() {
  return new Promise((resolve, reject) => {
    setTimeout(function() {
      test++;

      if (test === 4) {
        return resolve({
          reg: "reg value"
        });
      }

      reject({
        msg: "not ready"
      });

    }, 1000);
  });
}

function retryReg() {
  GetRegValue()
    .then(registryObj => {
      console.log(`got registry obj: ${JSON.stringify(registryObj)}`)
    })
    .catch(fail => {
      console.log(`registry object is not ready: ${JSON.stringify(fail)}`);
      retryReg();
    });
}

retryReg();

Answer 2

我不明白你为什么需要这条线：

.catch(err => { throw err });

while 的循环条件在这种情况下用处不大，因为您实际上不需要状态变量或表达式来确定循环是否应该继续：

let val;
while (true)
{
    try {
       val = await GetRegValue(/* args */);
       break;

    } catch (x) {
        console.log(x); // or something better
    }

    await delay(100);
}

如果对val 的赋值成功，我们将它传递给break; 语句，因此我们成功退出循环。否则我们跳转到catch 块并记录错误，等待 100 毫秒再试一次。

使用for 循环可能会更好，因此对重试次数设置合理的限制。

请注意，delay 在npm package of the same name 中可用。大致相同：

await new Promise(res => setTimeout(res, 100));