Golang Timers Tickers 使用详解

olzhy · 2019-07-02 08:14:45 · 1575 次点击 · 预计阅读时间 11 分钟 · 大约8小时之前开始浏览

这是一个创建于 2019-07-02 08:14:45 的文章，其中的信息可能已经有所发展或是发生改变。

业务中，会有对某段逻辑在未来某一时刻执行或以一定时间间隔周期性执行的需求。golang使用timer及ticker来满足该需求场景。
1 Timers
Timer表示在未来某一刻执行仅一次的事件。如下代码中，第一个timer表示1s后执行，<-timer.C会一直阻塞，直至预定时间到达。第二个timer表示2s后执行，新启一个goroutine等待时间到达，主routine在时间未到达前即调用了Stop()，这样，新启的goroutine中的逻辑即不会被执行。

package main
import (
"fmt"
"time"
)
func main() {
timer := time.NewTimer(time.Second)
<-timer.C
fmt.Println("hello")
timer = time.NewTimer(2 * time.Second)
go func() {
<-timer.C
fmt.Println("world")
}()
if timer.Stop() {
fmt.Println("timer stoped")
}
}

time.AfterFunc亦可以创建一个timer，func参数可以是时间到达后自定义的执行函数。

package main
import (
"fmt"
"time"
)
func main() {
done := make(chan bool)
time.AfterFunc(time.Second, func() {
fmt.Println("hello")
done <- true
})
<-done
}

一个通常错误的认为是，创建N个timer（无论是以time.NewTimer方式还是以time.AfterFunc方式）会伴随创建出N个goroutine来跟踪对应的指定时间，以在时间到达时执行。如下代码中，开始时，为了可以查询到系统级goroutine堆栈，加了一行代码debug.SetTraceback("system")。不传任何参数会打印创建timer前的堆栈信息，传入一个参数，会打印创建完10000个timer后的堆栈。创建timer前的goroutine数：

$ go run test.go 2>&1 | grep "^goroutine" | wc -l
4

大量创建timer后的goroutine数：

$ go run test.go hello 2>&1 | grep "^goroutine" | wc -l
5

可以发现创建10000个timer仅创建了一个监听goroutine。这是由于runtime/time.go内部使用堆统一管理timer，新建或停止timer仅是在对堆节点作增删，堆将要执行的timer排序，最近一个节点到达执行时间，即执行，有timer停止即从堆中移除，所以多个timer仅统一使用一个goroutine作调度即可。 https://github.com/golang/go/blob/master/src/runtime/time.go

package main
import (
"os"
"runtime/debug"
"time"
)
func main() {
debug.SetTraceback("system")
if len(os.Args) <= 1 {
panic("before")
}
for i := 0; i < 10000; i++ {
time.NewTimer(time.Second)
// time.AfterFunc(time.Second, func() {})
}
panic("after")
}

2 Tickers
Ticker表示一个按一定时间间隔周期性执行的事件。其创建与Timer类似。如下代码中，创建一个每隔1s即触发执行的ticker，新启一个goroutine遍历其时钟chan打印时间，主routine等待5s后停止该ticker，新启的goroutine即不会再收到消息。