NodeJS在无法及时完成promise时超时

Question

我怎样才能在一定的时间后超时一个承诺？我知道Q有一个承诺超时，但我使用的是原生NodeJS承诺，它们没有.timeout函数。

是我少了一个还是它的包装方式不同？

或者，下面的实现在不占用内存方面是否很好，实际上是按照预期工作的？

同样，我可以使它以某种方式进行全局包装，以便我可以在创建的每个承诺中使用它，而不必重复setTimeout和clearTimeout代码吗？

function run() {
    logger.info('DoNothingController working on process id {0}...'.format(process.pid));

    myPromise(4000)
        .then(function() {
            logger.info('Successful!');
        })
        .catch(function(error) {
            logger.error('Failed! ' + error);
        });
}

function myPromise(ms) {
    return new Promise(function(resolve, reject) {
        var hasValueReturned;
        var promiseTimeout = setTimeout(function() {
            if (!hasValueReturned) {
                reject('Promise timed out after ' + ms + ' ms');
            }
        }, ms);

        // Do something, for example for testing purposes
        setTimeout(function() {
            resolve();
            clearTimeout(promiseTimeout);
        }, ms - 2000);
    });
}

谢谢！

Answer 1

虽然可能不支持承诺超时,但您可以赛跑承诺：

null

var race = Promise.race([
  new Promise(function(resolve){
    setTimeout(function() { resolve('I did it'); }, 1000);
  }),
  new Promise(function(resolve, reject){
    setTimeout(function() { reject('Timed out'); }, 800);
  })
]);

race.then(function(data){
  console.log(data);
  }).catch(function(e){
  console.log(e);
  });

Answer 2

本机JavaScript承诺没有任何超时机制。

关于您的实现的问题可能更适合http://codereview.stackExchange.com，但需要注意以下几点：

>

您没有提供在承诺中实际执行任何操作的方法，并且

在settimeout回调中不需要cleartimeout，因为settimeout会安排一个一次性计时器。

既然一个承诺一旦被解决/拒绝就不能被解决/拒绝，那么你就不需要那张支票了。

所以也许有这样的东西：

function myPromise(ms, callback) {
    return new Promise(function(resolve, reject) {
        // Set up the real work
        callback(resolve, reject);

        // Set up the timeout
        setTimeout(function() {
            reject('Promise timed out after ' + ms + ' ms');
        }, ms);
    });
}

这样使用：

myPromise(2000, function(resolve, reject) {
    // Real work is here
});

（或者您可能希望它更复杂一些，请参阅下面一行的update。）

我会稍微担心语义略有不同（没有new，而您确实将new与promise构造函数一起使用），因此可以对其进行调整。

当然，另一个问题是，大多数时候，你不想构建新的承诺，所以不能使用上面的内容。大多数情况下，您已经有了一个承诺（前一个then调用的结果，等等）。但是对于真正构建一个新的承诺的情况，您可以使用类似于上面的东西。

您可以通过子类化promise来处理new事件：

class MyPromise extends Promise {
    constructor(ms, callback) {
        // We need to support being called with no milliseconds
        // value, because the various Promise methods (`then` and
        // such) correctly call the subclass constructor when
        // building the new promises they return.
        // This code to do it is ugly, could use some love, but it
        // gives you the idea.
        let haveTimeout = typeof ms === "number" && typeof callback === "function";
        let init = haveTimeout ? callback : ms;
        super((resolve, reject) => {
            init(resolve, reject);
            if (haveTimeout) {
                setTimeout(() => {
                    reject("Timed out");
                }, ms);
            }
        });
    }
}

用法：

let p = new MyPromise(300, function(resolve, reject) {
    // ...
});
p.then(result => {
})
.catch(error => {
});

现场示例：

null

// Uses var instead of let and non-arrow functions to try to be
// compatible with browsers that aren't quite fully ES6 yet, but
// do have promises...
(function() {
    "use strict";
    
    class MyPromise extends Promise {
        constructor(ms, callback) {
            var haveTimeout = typeof ms === "number" && typeof callback === "function";
            var init = haveTimeout ? callback : ms;
            super(function(resolve, reject) {
                init(resolve, reject);
                if (haveTimeout) {
        	        setTimeout(function() {
    	                reject("Timed out");
	                }, ms);
                }
            });
        }
    }
    
    var p = new MyPromise(100, function(resolve, reject) {
        // We never resolve/reject, so we test the timeout
    });
    p.then(function(result) {
    	snippet.log("Resolved: " + result);
    }).catch(function(reject) {
        snippet.log("Rejected: " + reject);
    });
})();

<!-- Script provides the `snippet` object, see http://meta.stackexchange.com/a/242144/134069 -->
<script src="http://tjcrowder.github.io/simple-snippets-console/snippet.js"></script>