golang定时器和超时的使用详解
我就废话不多说了，大家还是直接看代码吧~
funcmain(){
varachanstring
a=make(chanstring)
gosendDataTo(a)
gotiming()
getAchan(10*time.Second,a)
}
funcsendDataTo(achanstring){
for{
a<-"我是a通道的数据"
time.Sleep(1e9*3)
}
}
//在一定时间内接收不到a的数据则超时
funcgetAchan(timeouttime.Duration,achanstring){
varafter<-chantime.Time
loop:
after=time.After(timeout)
for{
fmt.Println("等待a中的数据，10秒后没有数据则超时")
select{
casex:=<-a:
fmt.Println(x)
gotoloop
case<-after:
fmt.Println("timeout.")
return
}
}
}
functiming(){
//定时器，10秒钟执行一次
ticker:=time.NewTicker(10*time.Second)
for{
time:=<-ticker.C
fmt.Println("定时器====>",time.String())
}
}
补充：golang的定时器NewTimer、NewTicker使用
废话不多说，直接看代码
packagemain
import(
"fmt"
"sync"
"time"
)
/**
*ticker只要定义完成，从此刻开始计时，不需要任何其他的操作，每隔固定时间都会触发。
*timer定时器，是到固定时间后会执行一次
*如果timer定时器要每隔间隔的时间执行，实现ticker的效果，使用func(t*Timer)Reset(dDuration)bool
*/
funcmain(){
varwgsync.WaitGroup
wg.Add(2)
//NewTimer创建一个Timer，它会在最少过去时间段d后到期，向其自身的C字段发送当时的时间
timer1:=time.NewTimer(2*time.Second)
//NewTicker返回一个新的Ticker，该Ticker包含一个通道字段，并会每隔时间段d就向该通道发送当时的时间。它会调
//整时间间隔或者丢弃tick信息以适应反应慢的接收者。如果d<=0会触发panic。关闭该Ticker可
//以释放相关资源。
ticker1:=time.NewTicker(2*time.Second)
gofunc(t*time.Ticker){
deferwg.Done()
for{
<-t.C
fmt.Println("getticker1",time.Now().Format("2006-01-0215:04:05"))
}
}(ticker1)
gofunc(t*time.Timer){
deferwg.Done()
for{
<-t.C
fmt.Println("gettimer",time.Now().Format("2006-01-0215:04:05"))
//Reset使t重新开始计时，（本方法返回后再）等待时间段d过去后到期。如果调用时t
//还在等待中会返回真；如果t已经到期或者被停止了会返回假。
t.Reset(2*time.Second)
}
}(timer1)
wg.Wait()
}
运行结果：
getticker12018-09-0722:44:29
gettimer2018-09-0722:44:29
...
额外说明：
time.NewTicker定时触发执行任务，当下一次执行到来而当前任务还没有执行结束时，会等待当前任务执行完毕后再执行下一次任务。查阅go官网的文档和经过代码验证。
time.NewTimer和Reset()函数实现定时触发，Reset()函数可能失败，经测试。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持毛票票。如有错误或未考虑完全的地方，望不吝赐教。