具有“isResolved”终止条件的递归同步函数

Question

目前，我定义了两个函数如下：

function getLock() {
  let promise, isPending;
  if (Math.random() > 0.5) {
    promise = new Promise((resolve, reject) => setTimeout(resolve, 1000));
    isPending = true;
  } else {
    promise = Promise.resolve();
    isPending = false;
  }
  return [promise, isPending];
};

function waitForLock() {
  const lockAndIsPending = getLock();
  const lock = lockAndIsPending[0];
  const isPending = lockAndIsPending[1];

  if (!isPending) {
    return lock;
  } else {
    return lock.then(waitForLock);
  }
}

waitForLock().then(() => console.log("done"));

这当然只是为了演示。作为现实世界应用程序的必需品，getLock 总是需要返回一个 Promise。 另外，锁被释放一次后，必须检查它是否仍然被释放（lock.then(waitForLock)），因为实际的释放条件（这里由Math.random()建模）可能同时由于异步而发生变化。这引入了递归。

我当前的代码工作正常：waitForLock() 最终会返回，因为它会在某个时候发生getLock 返回isPending=false，满足终止条件。

但我的目标是摆脱 isPending 作为额外的返回变量。将来，getLock 应该只返回一个承诺。不幸的是，无法检查给定的承诺是否已经解决（参见here），因此我无法在waitForLock 中“计算”isPending。那么如何相应地更改waitForLock？

编辑

目标是能够为getLock 使用任何Promise-returning 函数，而对返回或解析值没有特殊限制。所以，如果可能的话，逻辑应该都在waitForLock，而不是getLock。

Answer 1

如果我正确理解您要做什么，您只需要一个函数，它以任何一种方式返回一个 Promise，然后等待它：

function getLock() {
  let promise;

  if (Math.random() > 0.5) {
    console.log("Waiting to unlock...")
    promise = new Promise((resolve, reject) => setTimeout(() => resolve("Unlocked!"), 1000));
  } else {
    console.log("Unlocking immediately.")
    promise = Promise.resolve("Unlocked!");
  }
  return promise;
};

// Testing the above function
(async() => {
  for (let i in [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]) {
    console.log(await getLock())
  }
  console.log("All done")
})()

您甚至可以并行等待所有这些：

function getLock() {
  let promise;

  if (Math.random() > 0.5) {
    console.log("Waiting to unlock...")
    promise = new Promise((resolve, reject) => setTimeout(() => resolve("Unlocked!"), 1000));
  } else {
    console.log("Unlocking immediately.")
    promise = Promise.resolve("Unlocked!");
  }
  return promise;
};

// Testing the above function
(async() => {
  await Promise.all([1,2,3,4,5,6,7,8,9,10].map(getLock))
  console.log("All done")
})()

Answer 2

我认为你可以这样做

function getLock() {
  if (Math.random() > 0.5) {
    return new Promise((resolve, reject) => setTimeout(resolve, 1000));
  }

  return Promise.resolve('pending');
};

function waitForLock() {
  const lock = getLock();

  return lock.then((result) => {
    if (result === 'pending') {
      return waitForLock();
    }

    return result;
  })
}

waitForLock().then(() => console.log("done"));