給出了以下兩個(gè)功能。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 秒執(zhí)行一次。所以我認(rèn)為帶模數(shù)的遞增索引應(yīng)該這樣做。但我注意到（尤其是在高流量服務(wù)器上）它似乎跳過了一些循環(huán)。我查看了我的日志，有時(shí)每 10 秒就有一次，但有時(shí)會(huì)有長(zhǎng)達(dá) 1 分鐘的間隔。有人知道為什么會(huì)這樣嗎？
1 回答
SMILET
TA貢獻(xiàn)1796條經(jīng)驗(yàn) 獲得超4個(gè)贊
我建議使用 atime.Ticker每 N 秒執(zhí)行一次操作。這樣，您就可以使用內(nèi)置計(jì)時(shí)器，并且僅在需要做某事時(shí)才喚醒 CPU。即使 CPU 使用率不高，time.Sleepfor 循環(huán)也不是最可靠的任務(wù)調(diào)度方式。例如（來自上面的鏈接）：
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)
? ? ? ? }
? ? }
}
- 1 回答
- 0 關(guān)注
- 131 瀏覽
添加回答
舉報(bào)
0/150
提交
取消