定时器使得咱们能够提早若干工夫执行某项工作,或者以某一时间周期性执行某项工作,Linux 零碎自身也具备定时器能力,Go 语言是定时器是基于零碎调用实现的吗?另外,Go 语言不是多协程吗,定时器触发时,是在哪个协程执行工作的呢?创立工作的协程吗?
基本操作
Go 语言 time 包提供了工夫 / 定时器相干的 API,如获取以后零碎工夫(能够达到纳秒级别),协程休眠指定工夫,提早指定工夫执行某项工作,以某一时间周期性执行某项工作等等,操作如下:
package main
import (
"fmt"
"time"
)
func main() {
// 纳秒工夫戳
t := time.Now().UnixNano()
fmt.Println(t) //1652510180050345000
// 秒工夫戳
t = time.Now().Unix()
fmt.Println(t) //1652510180
// 格式化显示工夫
fmt.Println(time.Now().Format("2006-01-02 15:04:05")) //2022-05-14 14:36:20
// 一秒后执行函数
time.AfterFunc(time.Second, func() {fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
})
// 以一秒为周期,定时触发
ticker := time.NewTicker(time.Second)
go func() {
for {
<- ticker.C // 工夫触发时,管道可读
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
}
}()
// 协程休眠 3 秒
time.Sleep(10 * time.Second)
}
留神格式化工夫显示工夫年月日时分秒,用的是 ”2006-01-02 15:04:05″,Format 办法应用其余格局如 ”2022-05-14 14:36:20″ 能够吗?按理说这两个工夫字符串格局是一样的,只是值不一样罢了,后果应该没区别。写个小程序测试下,你会发现,后果有点奇怪:
package main
import (
"fmt"
"time"
)
func main() {
// 格式化显示工夫
fmt.Println(time.Now().Format("2022-05-14 14:36:20"))
// 输入:141414-02-540 540:26:140
}
这是什么?为什么不是失常的年月日时分秒显示呢?这就须要钻研下 Go 语言 Format 办法,反对的格局标识,比方其余一些语言应用 Y 示意年,M 示意月等。Go 语言定义的年月日等标识如下:
const (
stdZeroMonth // "01"
stdZeroDay // "02"
stdHour = iota + stdNeedClock // "15"
stdZeroMinute // "04"
stdZeroSecond // "05"
stdLongYear = iota + stdNeedDate // "2006"
// 省略了其余标识定义
)
看到了吧,”2006″、”01″ 等才是 Go 语言定义的工夫格局标识,所以 ”2006-01-02 15:04:05″ 能力失常显示年月日时分秒,而其余如 ”2022-05-14 14:36:20″ 的后果就有些不合乎预期了。当然,这里还省略了很多其余工夫格局标识,就定义在 time/format.go 文件,有趣味的读者能够本人钻研。
再回顾下面的程序,time.AfterFunc 能够在指定工夫执行函数,time.NewTicker 能够以肯定工夫周期触发工夫,time.Sleep 能够使协程休眠肯定工夫(过期后再复原协程的调度),这如何实现呢?要晓得我的项目中可能大量应用定时器,Go 语言如何能在准确的工夫触发定时事件呢?另外 time.AfterFunc,执行函数时,是在哪个协程执行呢?增加定时器的协程吗?
实现原理 - 堆
Go 语言如何能在准确的工夫触发定时事件呢?这意味着定时器的增删改查效率必须要高,不然难道每次都遍历所有定时器,判断哪些该触发吗?如果保护所有定时器有序呢?只须要查找第一个定时器,如果到期了则触发,并且持续查找;如果未到期也就不必持续查找了,因为前面的到期工夫必定大于第一个定时器的到期工夫。然而为了保护有序,增加定时器、批改定时器以及删除定时器的效率又太低。
须要具备肯定的有序性,增删改查性能还要高,什么数据结构适合呢?有一种数据结构叫堆(最大堆,最小堆),以最小堆为例,它实质上是一棵齐全二叉树,只是要求任何一个节点的值,都小于左右两个子节点的值,所以根节点的值肯定是最小的。这样如果定时器应用了最小堆,只须要判断根节点是否到期,如果到期则触发并删除根节点,而删除的过程中还须要保障剩下的节点仍然满足最小堆的条件;这样一来,获取下一个最近到期的定时器,工夫复杂度仍然是 O(1)。那么,最小堆,节点的删除以及增加的工夫复杂度是多少呢?也是比拟低的,O(logn)。
一般二叉树节点通常须要左右 left、right 指针,而堆是齐全二叉树,能够基于数组实现的,为什么呢?因为父子节点的索引是有关系的,如下图:
堆在插入节点时,通常先增加到数组的最初,再与父节点比拟,如果满足堆的定义,则完结;否则,与父节点替换。继续比拟替换到根节点为止,这一过程称之为上浮。一棵节点数为 N 的齐全二叉树,高度为 logn,也就是说比拟替换最多须要执行 logn 次,即堆的插入工夫复杂度为 O(logn)。
堆在删除根节点时,通常先替换根节点与最初一个节点,再间接删除最初一个节点(也就是根节点);此时根节点可能不满足堆的定义,所以,还须要与左右两个子节点比拟。继续比拟替换到最初一个节点为止,这一过程称之为下沉。删除的工夫复杂度同样为 O(logn)。删除过程逻辑如下:
一般堆是齐全二叉树,而 Go 语言应用的是四叉树,为什么呢?树更低,工夫复杂度更低呗。联合咱们介绍的堆的插入与删除逻辑,咱们看看 Go 语言四叉堆的插入与上浮逻辑:
func siftupTimer(t []*timer, i int) int {tmp := t[i]
for i > 0 {// 四叉树,父节点索引是 (i - 1) / 4
p := (i - 1) / 4 // parent
if when >= t[p].when { // 父节点小于以后节点,break
break
}
t[i] = t[p] // 替换
i = p
}
if tmp != t[i] { // 替换
t[i] = tmp
}
return i
}
// 增加定时器
func doaddtimer(pp *p, t *timer) {i := len(pp.timers)
pp.timers = append(pp.timers, t)
siftupTimer(pp.timers, i)
// 如果是根节点,记录过期工夫(最小)if t == pp.timers[0] {atomic.Store64(&pp.timer0When, uint64(t.when))
}
}
Go 语言四叉堆的删除与下沉逻辑十分相似,这里就不再赘述,能够参考 runtime/time.go 文件,dodeltimer0 与 siftdownTimer 这两个函数。
另外能够看到,构造 timer 就代表了一个定时器,蕴含了定时器的过期工夫,执行周期,执行办法等等,定义如下:
type timer struct {// Timer wakes up at when, and then at when+period, ... (period > 0 only)
when int64
period int64
// 执行办法 + 参数
f func(any, uintptr)
arg any
seq uintptr
}
思考一下,Go 语言是多线程 + 多协程程序,如果多个协程并发增加定时器呢?如果全局只有一个定时器堆,是不是每次操作都须要加锁呢?Go 语言低版本就是这么实现的。当初是每一个 P 都保护了一个定时器堆,从 doaddtimer 函数就能看进去,传入了以后线程 M 绑定的 P,而定时器也是增加到该 P 的定时器堆。看看 P 构造定义的定时器相干字段:
type p struct {
// 定时器堆
timers []*timer
// The when field of the first entry on the timer heap.
// This is updated using atomic functions.
// This is 0 if the timer heap is empty.
// 定时器堆根节点的过期工夫(最小)timer0When uint64
}
最初读者要留神的是,time 包定义了很多定时器相干的函数,然而这些函数的具体实现往往是在 runtime 包,比方
func Sleep(d Duration) // 实现函数为 timeSleep
func startTimer(*runtimeTimer) //time.NewTicker、time.After 等都是基于 startTimer 函数增加的定时器
func stopTimer(*runtimeTimer) bool
func resetTimer(*runtimeTimer, int64) bool //timeSleep 基于 resetTimer 实现
能够简略看看 time.AfterFunc 函数的实现:
func AfterFunc(d Duration, f func()) *Timer {
t := &Timer{
r: runtimeTimer{when: when(d),
f: goFunc, // 启动一个协程执行函数 f
arg: f,
},
}
startTimer(&t.r)
return t
}
定时器与调度器 schedule
每一个 P 都保护一个定时器四叉堆,那么 Go 语言是在什么时候检测是否要定时器过期呢?这必定与调度器 schedule 无关了:
func schedule() {
// 检测定时器并执行
checkTimers(pp, 0)
// 查找可执行协程
}
func checkTimers(pp *p, now int64) (rnow, pollUntil int64, ran bool) {
// 最近过期的定时器
next := int64(atomic.Load64(&pp.timer0When))
if next == 0 {
// No timers to run or adjust.
return now, 0, false
}
if now == 0 {now = nanotime()
}
// 第一个定时器没有过期,返回
if now < next {return now, next, false}
if len(pp.timers) > 0 {adjusttimers(pp, now)
for len(pp.timers) > 0 {
// 运行定时器(获取第一个定时器,如果过期则执行,否则返回时间差)if tw := runtimer(pp, now); tw != 0 {
// 第一个定时器没有过期,完结循环
break
}
ran = true
}
}
}
这下都明确了,调度器 schedule 在查找可运行协程时,先通过 checkTimers 检测定时器是否过期,并执行。也就是说,定时器函数 f 是在调度调度栈执行的;而且,如果某一个协程长时间运行(假如也没有被抢占),也有可能导致定时器的延后触发。
零碎工夫
最初再思考一个问题,Go 语言获取工夫戳甚至能够准确到纳秒级别,按理来说,获取工夫通常须要通过零碎调用实现,而零碎调用又会导致程序的低性能。那么 Go 语言是如何高性能的实现零碎工夫的获取呢?
这里须要理解一个概念,Linux VDSO(virtual dynamic shared object),他是为了优化用户程序频繁的零碎调用,把零碎调用改成用户态的函数调用,gettimeofday 就是其中一个。
VDSO 的介绍能够参考文章:https://zhuanlan.zhihu.com/p/…
总结
本篇文章次要介绍了 Go 语言定时器的根本应用以及实现原理,堆(最大堆 / 最小堆)有很多利用场景,如定时器,优先级队列等等。用户程序可能增加很多定时工作,而调度器 schedule 在调度协程之前,会检测是否有定时工作到期,如果有则执行该定时工作。