22

我正在递归运行 setTimeout，所以我只想每分钟调用一次 API。

这是我的代码：

;(async function ticker (minutes) {
  try {
    const res = await coingecko.global()
    const { market_cap_percentage } = res.data.data
    dominance = { btc: market_cap_percentage.btc, eth: market_cap_percentage.eth }
    console.log({ dominance })
  } catch (ex) {
    console.log(ex.message)
  } finally {
    setTimeout(ticker, minutes * 60 * 1000)
  }
})(1)

问题是：

  • 当我启动我的服务器时，它会立即调用 API
  • 拨打第二个电话需要一分钟（预期行为）
  • 在第二次调用之后，它开始顺序调用 API，没有超时
4

6 回答 6

17

它会立即调用它，因为这就是您的代码所做的。它立即执行ticker(1)函数调用。

当您从 调用ticker 时setTimeout(ticker, ...)，您没有将minutes参数传递给该函数-这就是为什么setTimeout()没有正确延迟的原因。

如果您不希望它立即执行，那么摆脱IIFE并以setTimeout(). 然后，当您ticker()从setTimeout()回调中调用时，请务必将minutes参数传递给它，或者通过将第三个参数传递给它，或者setTimeout()为它创建一个小回调函数。

这是一个实现：

async function ticker(minutes) {
  try {
    const res = await coingecko.global()
    const { market_cap_percentage } = res.data.data
    dominance = { btc: market_cap_percentage.btc, eth: market_cap_percentage.eth }
    console.log({ dominance })
  } catch (ex) {
    console.log(ex.message)
  } finally {
    setTimeout(ticker, minutes * 60 * 1000, minutes);
  }
}

setTimeout(ticker, minutes * 60 * 1000, 1);
于 2021-01-24T20:01:47.290 回答
4

也许您只需要使用一些日程管理器，例如bree？

从您的代码开始

  1. 你在这里不需要IIFE。打电话setTimeout(() => ticker(1), minutes * 60 * 1000)
  2. 同样更改内部setTimeout调用以传递minutes参数，因为现在您只需传递undefined. 这意味着immediately对于setTimeout.
于 2021-01-24T20:03:42.647 回答
3

ticker期望minutes作为参数，因此在setTimeout. 除此之外，setTimeout在第一个参数中需要一个函数，所以我建议简单地传递一个调用你的函数的箭头ticker函数。请检查以下代码：

;(async function ticker (minutes) {
  try {
    const res = await coingecko.global()
    const { market_cap_percentage } = res.data.data
    dominance = { btc: market_cap_percentage.btc, eth: market_cap_percentage.eth }
    console.log({ dominance })
  } catch (ex) {
    console.log(ex.message)
  } finally {
    setTimeout(() => ticker(minutes), minutes * 60 * 1000)
  }
})(1)
于 2021-01-24T20:07:25.187 回答
1

这里已经有一些很好的解释，但我将稍微重构代码以利用 async/await 而不需要外部库。

首先，让我们创建setTimeout一个异步函数：

async function sleep(ms) {
  return new Promise(res => setTimeout(res, ms));
}

接下来，让我们使用它来代替setTimeout：

(async function ticker (minutes) {
  do {
    await sleep(minutes * 60 * 1000);
    await loadData();
  } while (true);

  async function loadData() {
    try {
      const res = await coingecko.global()
      const { market_cap_percentage } = res.data.data
      dominance = { btc: market_cap_percentage.btc, eth: market_cap_percentage.eth }
    } catch (err) {
      console.error(ex.message);
    }
  }
})(1)

这几乎是一样的，除了

  1. 服务器启动后等待一分钟
  2. 它总是会在请求之间等待一分钟

它也更容易理解和阅读，并且由于您使用 async/await，它坚持单一范例（而不是使用 async/await 和回调setTimeout）。

于 2021-01-25T13:55:18.063 回答
0

我认为jfriend00 的回答已经解决了这个问题。为了便于阅读，我建议您使用功能较少的方法：

;(async function ticker (minutes) {
  while(true) {
    await new Promise(res => setTimeout(res, minutes * 60 * 1000));
    try {
      const res = await coingecko.global()
      const { market_cap_percentage } = res.data.data
      dominance = { btc: market_cap_percentage.btc, eth: market_cap_percentage.eth }
      console.log({ dominance })
    } catch (ex) {
      console.log(ex.message)
    }
  }
})(1)
于 2021-01-24T20:09:06.010 回答
0

这是一个过于复杂且可能不适合的解决方案，setInterval. 我只是想展示我们如何使用它setInterval来实现相同的行为。

const fetch = require('isomorphic-fetch')
const url = 'https://jsonplaceholder.typicode.com/posts';


const closeThis = () => {
  let ids = [];
  async function executeThisShiz(minutes) {
    ids.forEach((id) => {
      clearInterval(id);
    })
    try {
      let res = await fetch(url);
      res = await res.json();
      console.log('yay')
      return res;
    } catch(e) {
        // maybe abort the timer idk?
        console.log('error', e);
    } finally {
      id = setInterval(() => {
          executeThisShiz(minutes);
      }, minutes*60*1000);
      ids.push(id);
    }
  }
  return {
    ids,
    executeThisShiz
  }
}

const {executeThisShiz} = closeThis();
executeThisShiz(0.1);
于 2021-01-24T21:01:32.897 回答