我有一个奇怪的错误

Question

给出了以下两个功能。func main() {    index := int(0)    for {        Loop(index)        index = (index + 1) % 86400 // Max interval: 1 day        time.Sleep(1 * time.Second)    }}func Loop(index int) {    if index%10 == 0 {        go doSomething...    }}我想每 10/60/3600 秒执行一次。所以我认为带模数的递增索引应该这样做。但我注意到（尤其是在高流量服务器上）它似乎跳过了一些循环。我查看了我的日志，有时每 10 秒就有一次，但有时会有长达 1 分钟的间隔。有人知道为什么会这样吗？

Answer 1

我建议使用 atime.Ticker每 N 秒执行一次操作。这样，您就可以使用内置计时器，并且仅在需要做某事时才唤醒 CPU。即使 CPU 使用率不高，time.Sleepfor 循环也不是最可靠的任务调度方式。例如（来自上面的链接）：

package main

import (

    "fmt"

    "time"

)

func main() {

    ticker := time.NewTicker(time.Second)

    defer ticker.Stop()

    done := make(chan bool)

    go func() {

        time.Sleep(10 * time.Second)

        done <- true

    }()

    for {

        select {

        case <-done:

            fmt.Println("Done!")

            return

        case t := <-ticker.C:

            fmt.Println("Current time: ", t)

        }

    }

}