19

承诺一个带有超时的函数调用

我已经看到许多资源提供了类似的示例,Promise.race用于在给定的时间段内使函数调用超时。这是一个很好的例子,说明如何Promise.race在实践中使用。这是一些示例代码:

function doWithinInterval(func, timeout) {
    var promiseTimeout = new Promise(function (fulfill, reject) {
       // Rejects as soon as the timeout kicks in
       setTimeout(reject, timeout);
    });
    var promiseFunc = new Promise(function (fulfill, reject) {
        var result = func(); // Function that may take long to finish
        // Fulfills when the given function finishes
        fulfill(result);
    });

    return Promise.race([promiseTimeout, promiseFunc]);
}

上面使用的简单方法Promise.race在超时之前func完成后立即拒绝承诺。否则,一旦func函数在超时间隔之前完成,项目就会完成。

这听起来不错且易于使用。

但是,这是在 Promise 中使用超时的最佳做法吗?

当然,如果我们想使用 Promises 为函数调用设置超时,则可以使用上述方法。这些行动似乎仍然是一个很好的承诺。但是,这是否被认为是在 Promise 中使用超时的好习惯?如果没有,使用它有什么缺点?

我一直在寻找替代方法,但找不到本地 Promise 方法来做到这一点。

相反,一些外部 Promise 库提供timeout如下功能:

但是,Promise.timeout()它似乎不是标准 ECMAScript 6 API 的一部分(如果我错了,请纠正我)。是否有任何推荐的方法来使用 ES6 Promises 本地处理超时?

4

2 回答 2

15

这取决于你的意思timeout

如果您希望该功能停止,那么不会。

如果你只是想停止等待它,那么可以(在 ES6 中快速启动):

var wait = ms => new Promise(resolve => setTimeout(resolve, ms));
var timeout = (p, ms) => Promise.race([p, wait(ms).then(() => {
    throw new Error("Timeout after " + ms + " ms");
})]);

var wait = ms => new Promise(resolve => setTimeout(resolve, ms));
var timeout = (p, ms) => Promise.race([p, wait(ms).then(() => {
  throw new Error("Timeout after " + ms + " ms");
})]);

// Example:

var log = msg => div.innerHTML += "<p>" + msg + "</p>";
var failed = e => log(e.toString() + ", line " + e.lineNumber);

log("Waiting 5 seconds...");
timeout(wait(5000), 2000)
.then(() => log("...Done."))
.catch(failed);
<div id="div"></div>

如果您想取消操作(使其停止),那么希望该操作附带一个 API 来取消它,并且您应该使用它,因为 ES6 承诺不是控制界面。

可取消的承诺在 ES6 中是一个有争议的话题,但是提到的一些库确实提供了这个概念。

于 2015-06-19T14:05:29.933 回答
13

本机 Promise.race 方法在实际 Promise 完成后不会清除超时 Promise 的计时器,因此该过程将等待直到超时 Promise 也完成。这意味着如果您将超时设置为 1h 并且我们的承诺在 1 分钟后完成,那么该进程将等待 59 分钟然后退出。

请改用此方法:

export function race({promise, timeout, error}) {
  let timer = null;

  return Promise.race([
    new Promise((resolve, reject) => {
      timer = setTimeout(reject, timeout, error);
      return timer;
    }),
    promise.then((value) => {
      clearTimeout(timer);
      return value;
    })
  ]);
}
于 2016-10-04T12:29:07.853 回答