Timer
使用time.NewTimer()创建Timer后,经过其指定的时间后,它会向其管道发送当前时间。time.After()也是创建Timer,不过返回值不是Timer而是其管道。
package main
import (
"fmt"
"sync"
"time"
)
func main(){
//5秒后将当前时间发送给管道
timer:=time.NewTimer(time.Second*2)
if t,ok:=<-timer.C;ok{
fmt.Println(t)
}
//After()内部调用NewTimer()然后返回其管道
timeChan:=time.After(time.Second*2)
if t,ok:=<-timeChan;ok{
fmt.Println(t)
}
}
调用Timer的Reset()方法可以重置Timer,不过要注意的是在这之前需要确保Timer的管道里没有数据,如果有数据的情况下重置Timer,程序会立即读取到管道的数据,使逻辑出错。
所以正确调用Reset()的方法是:先调用Stop()停止Timer,如果Stop()返回false,说明管道可能有数据,需要先取出来再调用Reset(),Stop()方法也是同样的道理。
如果Timer停止或者时间到了,Reset()或Stop()会返回false,如果时间还没到则返回true。
package main
import (
"fmt"
"time"
)
func main(){
timer:=time.NewTimer(time.Second*2)
if t,ok:=<-timer.C;ok{
fmt.Println(t)
}
//正确重置Timer
if !timer.Stop() && len(timer.C) > 0{
<-timer.C
}
timer.Reset(time.Second*5)
if t,ok:=<-timer.C;ok{
fmt.Println(t)
}
}
time.AfterFunc()可以在指定时间后启动一个goroutine执行指定的函数,其返回值为Timer,我们可以通过调用Timer的Stop()方法取消这一过程。
package main
import (
"fmt"
"sync"
"time"
)
func main(){
//5秒后启动一个goroutine执行函数
var wg sync.WaitGroup
wg.Add(1)
time.AfterFunc(time.Second*5, func() {
fmt.Println("hello world")
wg.Done()
})
wg.Wait()
}
Ticker
使用time.NewTicker创建Ticker后每隔指定时间,它都会向其管道发送当前时间,调用Stop()方法停止发送。
package main
import (
"fmt"
"time"
)
func main(){
ticker:=time.NewTicker(time.Second)
for {
if t,ok:=<-ticker.C;ok{
fmt.Println(t)
}
}
}