使用 setInterval() 的无限异步循环 [重复]

Question

我有 nodejs 应用程序，它需要一些调用异步函数的无限循环。我正在考虑实施以下措施：

async function execute1() {
   ...do some async work...
}

async function execute2() {
   ...do some async work...
}

setInterval(execute1, 500)
setInterval(execute2, 500)

我担心的是，如果异步函数需要很长时间才能完成，打开的引用会堆积起来，这可能会导致内存崩溃。

1. setInterval 是适合这项工作的工具吗？有没有更合适的工具？
2. 如果之前的运行没有返回，确保 execute() 函数不会启动的最优雅的方法是什么？

Answer 1

setTimeout 在这种情况下可能会更好。

async function execute1(delay) {
   // await ...
   setTimeout(() => execute1(delay), delay)
}
execute1(500)

Answer 2

您可以使用简单的标志来指示之前的功能是否仍在运行

let isRunning = false;

async function execute1() {
   if (isRunning) return;
   isRunning = true

   ...do some async work...

   // make sure to call this whether it succeeds or fails, maybe in a finally block
   isRunning = false
}

setInterval(execute1, 500)

Answer 3

setInterval 不是正确的工具，因为它不知道 Promise 并且无法保持正确的控制流。

可以是async函数无限循环：

async function execute1() {
  while (true) {
    await new Promise(resolve => setTimeout(resolve, 500));
    // ...do some async work...  
  }
}

execute1();

Answer 4

您可以创建一个运行execute1() 的函数，然后等待它完成，然后使用setTimeout() 自行运行。

function randomSleep() {
  return new Promise(resolve => setTimeout(resolve, Math.random() * 3000));
}

let done = 0;

async function execute1() {
   console.log('Execute 1 started.')
   await randomSleep()
   return 'done'
}

const run = () => {
  execute1().then(result => {
    console.log('Execute 1 ended')
    done++
    console.log(`Done ${done} times.`)
    console.log(`Now waiting for 2 seconds`)
    setTimeout(() => {
      run()
    }, 2000)
  })
}

run()