异步函数中的 SetTimeout 和 setInterval

Question

   var processStatusCheck = setInterval(function statusCheck() {
    sequelize.query(dbQuery).then(function (data) {
       winston.info(' Status:', importStatus);
      if (importStatus ===  true) {
        winston.info('Inside', pollCount);
        clearInterval(processStatusCheck);
        addProcess(Id, function (response) {
               res.send(200)
        });
      } else {
        if(pollCount > 15){
          winston.info('It came here !!!', pollCount);
           res.sendStatus(500);      
        }else{
          winston.info('Incrementing.....');
          pollCount++;
          setTimeout(statusCheck, 18000);
        }
      }
    });
  }, 5000);

我正在尝试实现一个异步 Javascript 函数。我想不断地查询数据库，直到状态变为真，

最初调用是在 5 秒后根据 setInterval 进行的，但一旦达到 setTimeout，它就会连续调用该函数。我希望它在 18 秒后被调用。 如果 setTimmeout 中的时间少于 5 秒，则会立即发送响应，并且我收到“发送后无法设置标头”错误。

这里有 setInterval 和 setTimeout 导致我出现问题吗？请指导我。

Answer 1

仍然没有遵循所需的逻辑，因为您还没有真正解释您期望它如何工作。我将描述你在做什么，并指出该流程中的几个缺陷。

1. 您开始一个间隔，每 5 秒运行一次。
2. 直到importStatus 变为true，但此循环中没有设置importStatus，因此它似乎永远不会满足。
3. 您在循环内执行数据库查询，但甚至从未引用数据库查询的结果。我认为这不可能是正确的。同样，您发布的内容中一定缺少一些代码。
4. 然后，在间隔 15 次迭代后，您还开始每 18 秒执行一次setTimeout()。
5. 因此，5 秒间隔和 18 秒setTimeout() 都在运行。
6. 然后，在 15 次迭代后，您执行 res.sendStatus(500)，但永远不要停止 setInterval()，它会一直运行并在每次触发时一直尝试执行 res.sendStatus(500)。

问题总结：

1. 此代码中的任何内容都不会对importStatus 进行任何操作，因此基于此代码它永远不会是true。我假设您的真实代码必须与您在此处显示的不同。
2. 如果importStatus 永远不是true（参见上一点），那么您永远不会停止间隔——它会永远运行。您需要停止间隔计时器，可能在几个地方。当你做res.sendStatus(500)时当然要停止它，当你开始做setTimeout()时也可能停止它。
3. 在间隔 15 次迭代后，您开始设置 setTimeout() 18 秒。所以，现在间隔和setTimeout() 都在运行。你似乎不太可能想要那样。当您开始执行setTimeout() 时，也许您应该停止setInterval()
4. addProcess() 展示了一个异步风格的回调接口，但没有机会进行错误处理。真的是一个不会出错的函数吗？
5. 您甚至从未引用数据库查询结果data，因此从未使用过该查询。

编辑您的评论：

这是我要实现的逻辑。 1) 每 10 秒轮询数据库 15 次。 2）即使在1分半钟后，如果状态不正确，发送500并停止进程。

嗯，15 次，每次 10 秒和 1-1/2 分钟并不是全部加起来的。 15 次，每次 10 秒为 150 秒，即 2-1/2 分钟。这是一个在 10 秒内执行 15 次的实现。您可以根据需要调整数字。

  let pollCount = 0;
  const processStatusCheck = setInterval(function statusCheck() {
    sequelize.query(dbQuery).then(function (data) {
       if (someCondition) {
            clearInterval(processStatusCheck);
            addProcess(Id, function (response) {
               res.send(200)
            });
       } else {
            ++pollCount;
            if (pollCount > 15) {
                clearInterval(processStatusCheck);
                res.sendStatus(500);
            }
       }
  }, 10 * 1000);