热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Go(Golang)语言Golang定时器Timer和Ticker、time.AfterFunc、time.NewTicker()实例

文章目录Golang定时器Timer和Tickertime.Timertime.NewTimer()实例time.AfterFunctime.Tickertime.NewTicke

文章目录

  • Golang 定时器Timer和Ticker
    • time.Timer
      • time.NewTimer()实例
    • time.AfterFunc
    • time.Ticker
      • time.NewTicker()实例
      • [重要]time.NewTicker()使用总结


Golang 定时器Timer和Ticker

Golang 定时器包括:一次性定时器(Timer)和周期性定时器(Ticker)。

编程中经常会通过timer和ticker、AfterFunc定时器NewTicker是设定每隔多长时间触发的,是连续触发,而计时器NewTimer是等待多长时间触发的,只触发一次,两者是不同的。等待时间函数AfterFunc是在After基础上加了一个回调函数,是等待时间到来后在另外一个goroutine协程里调用。

  • Timer
    timer创建有两种方式,time.NewTimer(Duration) 和time.After(Duration)。 后者只是对前者的一个包装。
    timer到固定时间后会执行一次,请注意是一次,而不是多次。但是可以通过reset来实现每隔固定时间段执行。使用timer定时器,超时后需要重置,才能继续触发。

  • Ticker
    ticker只要定义完成,从此刻开始计时,不需要任何其他的操作,每隔固定时间都会触发。它会以一个间隔(interval)往通道发送当前时间,而通道的接收者可以以固定的时间间隔从通道中读取时间。


time.Timer

首先我们看Timer的结构定义:

type Timer struct {C <-chan Timer runtimeTimer
}

其中有一个C的只读channel&#xff0c;还有一个runtimeTimer类型的结构体&#xff0c;再看一下这个结构的具体结构&#xff1a;

type runtimeTimer struct {tb uintptri intwhen int64period int64f func(interface{}, uintptr) // NOTE: must not be closurearg interface{}seq uintptr
}

在使用定时timer的时候都是通过 NewTimer 或 AfterFunc 函数来获取。

func NewTimer(d Duration) *Timer {c :&#61; make(chan Time, 1)t :&#61; &Timer{C: c,r: runtimeTimer{when: when(d), //表示达到时间段d时候调用ff: sendTime, // f表示一个函数调用&#xff0c;这里的sendTime表示d时间到达时向Timer.C发送当前的时间arg: c, // arg表示在调用f的时候把参数arg传递给f&#xff0c;c就是用来接受sendTime发送时间的},}startTimer(&t.r)return t
}

定时器的具体实现逻辑&#xff0c;都在 runtime 中的 time.go 中&#xff0c;它的实现&#xff0c;没有采用经典 Unix 间隔定时器 setitimer 系统调用&#xff0c;也没有 采用 POSIX间隔式定时器&#xff08;相关系统调用&#xff1a;timer_create、timer_settime 和 timer_delete&#xff09;&#xff0c;而是通过四叉树堆(heep)实现的&#xff08;runtimeTimer 结构中的i字段&#xff0c;表示在堆中的索引&#xff09;。通过构建一个最小堆&#xff0c;保证最快拿到到期了的定时器执行。定时器的执行&#xff0c;在专门的 goroutine 中进行的&#xff1a;go timerproc()。有兴趣的同学&#xff0c;可以阅读 runtime/time.go 的。

time.NewTimer()实例

package mainimport ("fmt""time"
)func main() {myTimer :&#61; time.NewTimer(time.Second * 2) // 启动定时器var i int &#61; 0for {select {case <-myTimer.C:i&#43;&#43;fmt.Println("count: ", i)myTimer.Reset(time.Second * 2) // 每次使用完后需要人为重置下}}// 不再使用了&#xff0c;结束它myTimer.Stop()
}

使用timer定时器&#xff0c;超时后需要重置&#xff0c;才能继续触发。

time.AfterFunc

Go语言的AfterFunc()函数用于等待经过的时间&#xff0c;此后&#xff0c;它将在其自己的go-routine中调用已定义的函数“f”。此外&#xff0c;此函数在时间包下定义。在这里&#xff0c;您需要导入“time”包才能使用这些函数。

func AfterFunc(d Duration, f func()) *Timer

例子&#xff1a;

// Golang program to illustrate the usage of
// AfterFunc() function // Including main package
package main // Importing fmt and time
import ( "fmt""time"
) // Main function
func main() { // Defining duration parameter of // AfterFunc() method DurationOfTime:&#61; time.Duration(3) * time.Second // Defining function parameter of // AfterFunc() method f:&#61; func() { // Printed when its called by the // AfterFunc() method in the time // stated above fmt.Println("Function called by "&#43; "AfterFunc() after 3 seconds") } // Calling AfterFunc() method with its // parameter Timer1:&#61; time.AfterFunc(DurationOfTime, f) // Calling stop method // w.r.to Timer1 defer Timer1.Stop() // Calling sleep method time.Sleep(10 * time.Second)
}

time.Ticker

官网&#xff1a;https://pkg.go.dev/time#NewTicker

Golang time.Timer and time.Ticker
参考URL: https://www.jianshu.com/p/2b4686b8de4a

time.NewTicker()实例

官网&#xff1a;https://pkg.go.dev/time#NewTicker

官方demo

package mainimport ("fmt""time"
)func main() {ticker :&#61; time.NewTicker(time.Second)defer ticker.Stop()done :&#61; make(chan bool)go func() {time.Sleep(10 * time.Second)done <- true}()for {select {case <-done:fmt.Println("Done!")returncase t :&#61; <-ticker.C:fmt.Println("Current time: ", t)}}
}

Ticker是一个周期触发定时的计时器&#xff0c;它会按照一个时间间隔往channel发送系统当前时间&#xff0c;而channel的接收者可以以固定的时间间隔从channel中读取事件。

相关函数&#xff1a;
NewTicker() 返回一个新的Ticker&#xff0c;该Ticker包含一个通道字段&#xff0c;并会每隔时间段d就向该通道发送当时的时间。它会调整时间间隔或者丢弃tick信息以适应反应慢的接收者。如果d<&#61;0会panic。关闭该Ticker可以释放相关资源。
Stop() 关闭一个Ticker。在关闭后&#xff0c;将不会发送更多的tick信息。Stop不会关闭通道t.C&#xff0c;以避免从该通道的读取不正确的成功

demo2: time.NewTicker 周期时间到了&#xff0c;但是之前程序没有执行完,怎么处理&#xff1f;

package mainimport ("fmt""time"
)func main() {ticker :&#61; time.NewTicker(time.Second)defer ticker.Stop()done :&#61; make(chan bool)go func() {time.Sleep(10 * time.Second)done <- true}()for {select {case <-done:fmt.Println("Done!")returncase t :&#61; <-ticker.C:fmt.Println("Current time: ", t)time.Sleep(4 * time.Second)}}
}

经过代码验证&#xff1a;time.NewTicker定时触发执行任务&#xff0c;当下一次执行到来而当前任务还没有执行结束时&#xff0c;会等待当前任务执行完毕后再执行下一次任务。

[重要]time.NewTicker()使用总结


  1. ticker 创建完之后&#xff0c;不是马上就有一个 tick&#xff0c;第一个 tick 在 x 秒&#xff08;你自己写的&#xff09;之后
  2. Go语言的定时器实质是单向通道&#xff0c;time.Timer结构体类型中有一个time.Time类型的单向chan。
  3. **time.NewTicker定时触发执行任务&#xff0c;当下一次执行到来而当前任务还没有执行结束时&#xff0c;会等待当前任务执行完毕后再执行下一次任务。**查阅go官网的文档和经过代码验证。
  4. t.Stop()在这里并不会停止定时器。这是因为Stop会停止Timer&#xff0c;停止后&#xff0c;Timer不会再被发送&#xff0c;但是Stop不会关闭通道&#xff0c;防止读取通道发生错误。
    官方说明&#xff1a;Stop turns off a ticker. After Stop, no more ticks will be sent. Stop does not close the channel, to prevent a concurrent goroutine reading from the channel from seeing an erroneous “tick”.
    如果想停止定时器&#xff0c;只能让go程序自动结束。
  5. Ticker 跟 Timer 的不同之处&#xff0c;就在于 Ticker 时间达到后不需要人为调用 Reset 方法&#xff0c;会自动续期。

推荐阅读
author-avatar
Sunny-虫虫
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有