nodejs承诺设计中的内存泄漏？

Question

我注意到这里有些人建议在您想延迟执行某些事情时直接使用 await/async 和 promise 而不是 setTimeout。这是代码：

async wait (ms){
  return new Promise(resolve => setTimeout(resolve, ms));
}

所以我会使用

await wait(3000);
my_function();

而不是

setTimeout(() => {
  my_function();
}, 3000);

这是有道理的，但我注意到如果我这样做，我会增加内存使用量，并最终导致应用程序在几个小时后崩溃并出现大量内存。

这是 nodejs 的 Promise 设计中的问题，还是我在这里遗漏了什么？

---

这段代码重现了这个问题：

const heapdump = require('heapdump'),
      fs = require('fs');
class test {
  constructor(){
    this.repeatFunc();
  }
  async wait (ms){
    return new Promise(resolve => setTimeout(resolve, ms));
  }
  async repeatFunc(){ 
    // do some work...
    heapdump.writeSnapshot(__dirname + '/' + Date.now() + '.heapsnapshot');    

    await this.wait(5000); 
    await this.repeatFunc();
  }
}
new test();

注意堆转储每 5 秒增加一次

使用 setInterval 不会发生这种情况：

const heapdump = require('heapdump'),
      fs = require('fs');
class test {
  constructor() {
    setInterval(this.repeatFunc, 5000);
  }
  repeatFunc() { 
    // do some work...
    heapdump.writeSnapshot(__dirname + '/' + Date.now() + '.heapsnapshot');    
  }
}
new test();

Answer 1

你编写了一个无限递归函数，每个函数调用都会返回一个新的 Promise。每个承诺都在等待从内部解决 - 所以是的，它当然是在积累内存。如果代码是同步的，你会得到一个堆栈溢出异常。

只需使用循环：

const heapdump = require('heapdump'),
      fs = require('fs');

async function wait(ms){
  return new Promise(resolve => setTimeout(resolve, ms));
}
async function repeat() {
  while (true) {
    // do some work...
    heapdump.writeSnapshot(__dirname + '/' + Date.now() + '.heapsnapshot');    

    await wait(5000); 
  }
}

repeat().then(() => console.log("all done"), console.error);

---

我注意到这里有些人建议在您想延迟执行某事时直接使用await/async 和promise 而不是setTimeout。

包括我在内，因为 Promise 更容易使用，尤其是当您想要从异​​步任务返回结果值或处理错误时。但是，如果您不相信 Promise 的任何优点，那么没有什么可以强迫您将已经工作的代码转换为 Promise。继续使用回调样式，直到你找到对 Promise 的好用处。

Answer 2

为避免在 Promise 中发生内存泄漏，最好在使用后清除所有超时。

function wait(delay) {
    return new Promise(function(resolve) {
        let id = setTimeout(function() { resolve(); clearTimeout(id);  }, delay);
    });
}

(async () => {
   await wait(2000);
   alert("Test");
})();