(1)time.NewTimer,time.NewTicker,time.Tick的使用如下:
package main
import (
"errors"
"fmt"
"golang.org/x/sync/errgroup"
"time"
)
/**
* ticker只要定义完成,从此刻开始计时,不需要任何其他的操作,每隔固定时间都会触发。
* timer定时器,是到固定时间后值只会执行一次
* 如果timer定时器要每隔间隔的时间执行,实现ticker的效果,使用 func (t *Timer) Reset(d Duration) bool
*/
func main() {
var g errgroup.Group
g.Go(func() error {
timer := time.NewTimer(1 * time.Second)
for {
select {
case <-timer.C:
println("1_Tokyo_NewYork_London")
timer.Reset(1 * time.Second)
// 若要停止定时器就使用如下代码,这样会释放资源
// timer.Stop()
}
// break
}
return nil
})
g.Go(func() error {
ticker := time.NewTicker(1 * time.Second)
for {
select {
case <-ticker.C:
println("2_NewYork_London_Tokyo")
// 若要停止定时器就使用如下代码,这样会释放资源
// ticker.Stop()
}
// break
}
return errors.New("sgdagf")
})
// 上一个协程实现的功能一样的,但这time.Tick无法停止,也就是无法释放资源!
g.Go(func() error {
for {
select {
case <-time.Tick(1 * time.Second):
println("3_Singapore_London_Tokyo")
}
// fmt.Println(<-time.Tick(2 * time.Second))
}
})
if err := g.Wait(); err != nil {
fmt.Println("Err:",err)
} else {
println("finish")
}
}
(2)time.AfterFunc使用如下:
package main
import "time"
func main() {
f := func() { println("Tokyo_London_NewYork") }
// AfterFunc的内部又启动了一个协程,且这个定时器到了定时时间后,只会执行一次!
time.AfterFunc(2*time.Second, f)
time.Sleep(5 * time.Second)
}
下面这个情况会发生死锁!
package main
import (
"fmt"
"time"
)
func main() {
fmt.Println(time.Now())
f := func() { println("Tokyo_London_NewYork") }
// 执行下面的代码,会发生死锁!
fmt.Println(<-time.AfterFunc(2*time.Second, f).C)
}
(3)time.After使用如下:
package main
import (
"fmt"
"time"
)
func main() {
fmt.Println("3 second before:",time.Now())
// After函数到了定时时间后只有执行一次!并且返回过了定时时间后的当前时间!
fmt.Println("3 second after:", <-time.After(3*time.Second))
}
有疑问加站长微信联系(非本文作者)