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()函数可能失败,经测试。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持毛票票。如有错误或未考虑完全的地方,望不吝赐教。