一、知识点
golang定时器使用的类库是“time”,参考官方文档创建timer。官方提供了两种方式创建timer分别是:
1)func AfterFunc(d Duration, f func()) *Timer这方法大概意思是经过d时间间隔,就执行f函数。
2)func NewTimer(d Duration) *Timer这函数打个意思是创建一个timer每过去d时间间隔就发送当前时间到timer的channel里面。
3)补充一点chan的知识点,channel(通道)是golang里面线程通讯的通道。它分为带缓冲的通道和不带缓冲的通道。chan也可以创建为只输入通道或者只读入通道或者可读可写通道。举例:
ch := make(chan int) 无缓冲通道(可读可写通道)
ch := make(chan int, 10)缓冲为10的通道(可读可写通道)
ch := make(chan<- int)无缓冲通道(只写通道)
ch := make(<-chan int)无缓冲通道(只读通道)
二、实践
继续上一篇请求天气的demo。我们每隔十分钟定时获取一下最新天气。
创建timer执行时间是间隔10分钟:
timer := time.NewTicker(10* time.Minute)
for {
<-timer.C
rlt, err := doHttpGetRequest("https://restapi.amap.com/v3/weather/weatherInfo?key=你的高德key&city=110101")
if err != nil {
fmt.Println("net req error")
} else {
fmt.Println(rlt)
}
}
在上面代码中,有一行<-timer.C这句话说明下,首先我们看下timer的数据结构如下:
type Timer struct {
C <-chan Time
// contains filtered or unexported fields
}
timer中有一个只可写入的通道C变量。我们使用的是func NewTimer(d Duration) *Timer函数来创建timer。那么我们这个timer就是每十分钟中向这个通道C中写入当前时间。我们在代码中的这行<-timer.C只是为了把通道C的值进行读出操作。防止线程阻塞,timer无法正常运行。
PS:关于chan更详细的介绍参考
网友评论