现在我们创建了一个定时器,能定时的去做某件事,并且在执行时间超时的时候,能把这个定时器关掉。例如需要收集一周的日志,创建一个定时任务去收集日志,每5秒钟执行一次,一周的时间过后需要停掉这个定时任务。
标准库提供里的Ticker类,主要功能是定时重复的去做某件事情,如果没有设定超时,它会一直执行下去。常见的写法如下:
t := time.NewTicker(3 * time.Second) timeout := time.After(10 * time.Second) go func() { for { <-t.C ... } }() <-timeout ...注意到这个Ticker对象是无法关闭的,好的,你可能会发现Ticker类提供了Stop方法。但是我们看看如果你这样去关闭t的话,会出现什么情况。
package main import ( "fmt" "time" ) func DoTickerWork(res chan interface{}, timeout <-chan time.Time) { t := time.NewTicker(3 * time.Second) go func() { defer close(res) i := 1 for { <-t.C fmt.Printf("start %d th worker\n", i) res <- i i++ } }() <-timeout t.Stop() return } func main() { res := make(chan interface{}, 10000) timeout := time.After(10 * time.Second) DoTickerWork(res, timeout) for v := range res { fmt.Println(v) } }直觉上来看,新起的goroutine在等待的过程中,主线程会把定时器关掉,似乎没有什么bug,然而输出是这样:
$go run ticker.go start 1 th worker start 2 th worker start 3 th worker 1 2 3 fatal error: all goroutines are asleep - deadlock! goroutine 1 [chan receive]: main.main() /home/gepin.zs/go/src/timer/ticker.go:29 +0xad goroutine 6 [chan receive]: main.DoTickerWork.func1(0xc42006c060, 0xc4200161c0) /home/gepin.zs/go/src/timer/ticker.go:14 +0x8e created by main.DoTickerWork /home/gepin.zs/go/src/timer/ticker.go:19 +0x60 exit status 2这说明Ticker对象的stop方法并没有关掉这个Ticker的channel,而只是阻止了channel的数据写入,所以goroutine的任务依然在进行中,但是<-t.C一直阻塞,出现了deadlock的情况。可能会有人说调用close(t.C)就可以了,但是编译会报错:cannot close receive-only channel, 因为t.C是一个只读队列,无法调用close方法。
不要以为stop就可以关掉Ticker了,我们可以新建一个名字为done的channel,缓存大小为1,goroutine里面采用select,然后尝试获取timeout,如果能够取到,说明已经触发超时,然后close(done),这个时候任务结束,主线程return。代码如下:
package main import ( "fmt" "time" ) func DoTickerWork(res chan interface{}, timeout <-chan time.Time) { t := time.NewTicker(3 * time.Second) done := make(chan bool, 1) go func() { defer close(res) i := 1 for { select { case <-t.C: fmt.Printf("start %d th worker\n", i) res <- i i++ case <-timeout: close(done) return } } }() <-done return } func main() { res := make(chan interface{}, 10000) timeout := time.After(10 * time.Second) DoTickerWork(res, timeout) for v := range res { fmt.Println(v) } }程序返回结果
$go run ticker.go start 1 th worker start 2 th worker start 3 th worker 1 2 3