教程集 > Golang编程 > golang教程 > 正文 go语言-time.Ticker（定时任务实现）

go语言-time.Ticker（定时任务实现）

发布时间：2022-03-25 编辑：jiaochengji.com

教程集为您提供go语言-time.Ticker（定时任务实现）等资源，欢迎您收藏本站，我们将为您提供最新的go语言-time.Ticker（定时任务实现）资源

Go语言之time.Ticke
参考URL: Code.dev.xdja.com/diffusion/
Golang time.Timer and time.Ticker
参考URL: https://www.jianshu.com/p/2b4686b8de4a

time.Timer
首先我们看Timer的结构定义：

<pre><code class="lang-go hljs">type Timer struct { C <-chan Time r runtimeTimer } </code></pre>

其中有一个C的只读channel，还有一个runtimeTimer类型的结构体，再看一下这个结构的具体结构：

<pre><code class="lang-go hljs">type runtimeTimer struct { tb uintptr i int when int64 period int64 f func(interface{}, uintptr) // NOTE: must not be closure arg interface{} seq uintptr } </code></pre>

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

<pre><code class="lang-go hljs">func NewTimer(d Duration) *Timer { c := make(chan Time, 1) t := &Timer{ C: c, r: runtimeTimer{ when: when(d), //表示达到时间段d时候调用f f: sendTime, // f表示一个函数调用，这里的sendTime表示d时间到达时向Timer.C发送当前的时间 arg: c, // arg表示在调用f的时候把参数arg传递给f，c就是用来接受sendTime发送时间的 }, } startTimer(&t.r) return t } </code></pre>

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

<h3>使用举例</h3> <pre><code class="lang-go hljs">package main import ( "fmt" "time" ) func main() { //创建定时器，每隔1秒后，定时器就会给channel发送一个事件(当前时间) ticker := time.NewTicker(time.Second * 1) i := 0 go func() { for { //循环 <-ticker.C i fmt.Println("i = ", i) if i == 5 { ticker.Stop() //停止定时器 } } }() //别忘了() //死循环，特地不让main goroutine结束 for { } } </code></pre>

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

go语言-time.Ticker（定时任务实现）

最近更新

浏览排行