定时器不管是业务开发,还是基础架构开发,都是绕不过去的存在,由此可见定时器的重要程度。
我们不管用 newtimer, timer.after,还是 timer.afterfun 来初始化一个 timer, 这个 timer 最终都会加入到一个全局 timer 堆中,由 go runtime 统一管理。
全局的 timer 堆也经历过三个阶段的重要升级。
go 1.9 版本之前,所有的计时器由全局唯一的四叉堆维护,协程间竞争激烈。go 1.10 - 1.13,全局使用 64 个四叉堆维护全部的计时器,没有本质解决 1.9 版本之前的问题go 1.14 版本之后,每个 p 单独维护一个四叉堆。go 1.14 以后的 timer 性能得到了质的飞升,不过伴随而来的是 timer 成了 go 里面最复杂、最难梳理的数据结构。本文不会详细分析每一个细节,我们从大体来了解 go timer 的工作原理。
1. 使用场景go timer 在我们代码中会经常遇到。
场景1:rpc 调用的防超时处理(下面代码节选 dubbogo)
func (c *client) request(request *remoting.request, timeout time.duration, response *remoting.pendingresponse) error { _, session, err := c.selectsession(c.addr) // .. 省略 if totallen, sendlen, err = c.transfer(session, request, timeout); err != nil { if sendlen != 0 && totallen != sendlen { // .. 省略 } return perrors.withstack(err) } // .. 省略 select { case < -getty.gettimewheel().after(timeout): return perrors.withstack(errclientreadtimeout) case < -response.done: err = response.err } return perrors.withstack(err)}场景2:context 的超时处理
func main() { ctx, cancel := context.withtimeout(context.background(), 1*time.second) defer cancel() go dosomething() select { case timer.movetimers,将不再被使用的 p 的 timers 上有效的 timer(状态是:timerwaiting,timermodifiedearlier,timermodifiedlater) 都重新加入到一个新的 p 的 timer 上2.4 reset 时 timer 是如何被操作的?reset 的目的是把 timer 重新加入到 timer 堆中,重新等待被触发。不过分为两种情况:
被标记为 timerremoved 的 timer,这种 timer 是已经从 timer 堆上删除了,但会重新设置被触发时间,加入到 timer 堆中等待被触发的 timer,在 reset 函数中只会修改其触发时间和状态(timermodifiedearlier或timermodifiedlater)。这个被修改状态的 timer 也同样会被重新加入到 timer堆上,不过是由 gmp 触发的,由 checktimers 调用 adjusttimers 或者 runtimer 来执行的。
2.5 stop 时 timer 是如何被操作的?time.stop 为了让 timer 停止,不再被触发,也就是从 timer 堆上删除。不过 timer.stop 并不会真正的从 p 的 timer 堆上删除 timer,只会将 timer 的状态修改为 timerdeleted。然后等待 gmp 触发的 adjusttimers 或者 runtimer 来执行。
真正删除 timer 的函数有两个 dodeltimer,dodeltimer0。
2.6 timer 是如何被真正执行的?timer 的真正执行者是 gmp。gmp 会在每个调度周期内,通过 runtime.checktimers 调用 timer.runtimer(). timer.runtimer 会检查该 p 的 timer 堆上的所有 timer,判断这些 timer 是否能被触发。
如果该 timer 能够被触发,会通过回调函数 sendtime 给 timer 的 channel c 发一个当前时间,告诉我们这个 timer 已经被触发了。
如果是 ticker 的话,被触发后,会计算下一次要触发的时间,重新将 timer 加入 timer 堆中。
3. timer 使用中的坑确实 timer 是我们开发中比较常用的工具,但是 timer 也是最容易导致内存泄露,cpu 狂飙的杀手之一。
不过仔细分析可以发现,其实能够造成问题就两个方面:
错误创建很多的 timer,导致资源浪费由于 stop 时不会主动关闭 c,导致程序阻塞3.1 错误创建很多 timer,导致资源浪费func main() { for { // xxx 一些操作 timeout := time.after(30 * time.second) select { case < - somedone: // do something case < -timeout: return } }}上面这段代码是造成 timer 异常的最常见的写法,也是我们最容易忽略的写法。
造成问题的原因其实也很简单,因为 timer.after 底层是调用的 timer.newtimer,newtimer 生成 timer 后,会将 timer 放入到全局的 timer 堆中。
for 会创建出来数以万计的 timer 放入到 timer 堆中,导致机器内存暴涨,同时不管 gmp 周期 checktimers,还是插入新的 timer 都会疯狂遍历 timer 堆,导致 cpu 异常。
要注意的是,不只 time.after 会生成 timer, newtimer,time.afterfunc 同样也会生成 timer 加入到 timer 中,也都要防止循环调用。
解决办法: 使用 time.reset 重置 timer,重复利用 timer。
我们已经知道 time.reset 会重新设置 timer 的触发时间,然后将 timer 重新加入到 timer 堆中,等待被触发调用。
func main() { timer := time.newtimer(time.second * 5) for { timer.reset(time.second * 5) select { case < - somedone: // do something case < -timer.c: return } }}3.2 程序阻塞,造成内存或者 goroutine 泄露func main() { timer1 := time.newtimer(2 * time.second) < -timer1.c println(done)}上面的代码可以看出来,只有等待 timer 超时 done 才会输出,原理很简单:程序阻塞在 <-timer1.c 上,一直等待 timer 被触发时,回调函数 time.sendtime 才会发送一个当前时间到 timer1.c 上,程序才能继续往下执行。
不过使用 timer.stop 的时候就要特别注意了,比如:
func main() { timer1 := time.newtimer(2 * time.second) go func() { timer1.stop() }() < -timer1.c println(done)}程序就会一直死锁了,因为 timer1.stop 并不会关闭 channel c,使程序一直阻塞在 timer1.c 上。
上面这个例子过于简单了,试想下如果 <- timer1.c 是阻塞在子协程中,timer 被的 stop 方法被调用,那么子协程可能就会被永远的阻塞在那里,造成 goroutine 泄露,内存泄露。
stop 的正确的使用方式:
func main() { timer1 := time.newtimer(2 * time.second) go func() { if !timer1.stop() { < -timer1.c } }() select { case < -timer1.c: fmt.println(expired) default: } println(done)}
过零比较器电路的用途_过零比较器原理介绍
构建一个计时器电路的教程
HarmonyOS折叠屏设计规范的新增亮点内容
到2025年全球传感器市场复合年增长率为8.86%,将进一步创造市场竞争
成飞最新魔幻设计,新型隐身飞翼无人机?
Go timer的工作原理是什么?Go timer是如何被调度的?
vivo从去年就启动了6G研究项目
外媒曝华为Mate30系列或搭载麒麟985
智能电饭煲的结构及工作原理
为什么CANFD要对发送延迟做补偿?
放大器的工作参数可以略微高于绝对最大额定值吗
2018年,人脸识别领域有哪些值得关注的企业呢?
AI如何一步步构建和影响身边的世界
来自日本的陶瓷,小米MIX皓月白强势登场
村田发力MEMS传感器市场
郭明錤曝光iPhone SE3细节:2021年推出
中国移动5G精品网络建设的四大提升方面
高效软件开发过程的三个步骤
澜起科技全新第五代津逮®CPU上市!
威尔逊恒流源电路的仿真分析