golang:一个高性能低精度timer实现
2014-04-16 10:24
561 查看
在go自带的timer实现中,采用的是通常的最小堆的方式,具体可以参见这里。
最小堆能够提供很好的定时精度,但是,在实际情况中,我们并不需要这样高精度的定时器,譬如对于一个连接,如果它在2分钟以内没有数据交互,我们就将其删除,2分钟并不需要那么精确,多几秒少几秒都无所谓的。
以前我们单独实现了一个timingwheel,采用的是channel close的方式来处理低精度,超大量timer定时的问题,详见这里。
但是timingwheel只有After接口,远远不能满足实际的需求,于是我按照linux timer的实现方式,依葫芦画瓢,弄了一个go版本的实现。linux timer的实现,参考这篇。
后续用go timer来表示我自己实现的timer。
在linux中,我们使用tick来表示一次中断的时间,用jiffies来表示系统自启动以来流逝的tick次数。在go timer中,我们在创建一个wheel的时候,需要指定一次tick的时间,如下:
Wheel是go timer统一对timer进行管理的地方。对于每一次tick,我们采用go自带的ticker进行模拟。
为了便于外部使用,我仍然提供的是跟go自己timer一样的接口,譬如:
在NewTimer中,参数d是一个time duration,我们还需要根据tick来进行换算,得到go timer中实际的expires,也就是在多少次jiffies后该timer触发。
譬如,NewTimer参数为10s,tick为1s,那么经过10个jiffies之后,该timer就会超时触发。如果tick为500ms,那么需要经过20个jiffies之后,该timer才会被触发。
所以timer超时jiffies的计算如下:
详细的代码在https://github.com/siddontang/golib/tree/master/timer。
最小堆能够提供很好的定时精度,但是,在实际情况中,我们并不需要这样高精度的定时器,譬如对于一个连接,如果它在2分钟以内没有数据交互,我们就将其删除,2分钟并不需要那么精确,多几秒少几秒都无所谓的。
以前我们单独实现了一个timingwheel,采用的是channel close的方式来处理低精度,超大量timer定时的问题,详见这里。
但是timingwheel只有After接口,远远不能满足实际的需求,于是我按照linux timer的实现方式,依葫芦画瓢,弄了一个go版本的实现。linux timer的实现,参考这篇。
后续用go timer来表示我自己实现的timer。
在linux中,我们使用tick来表示一次中断的时间,用jiffies来表示系统自启动以来流逝的tick次数。在go timer中,我们在创建一个wheel的时候,需要指定一次tick的时间,如下:
func NewWheel(tick time.Duration) *Wheel
Wheel是go timer统一对timer进行管理的地方。对于每一次tick,我们采用go自带的ticker进行模拟。
为了便于外部使用,我仍然提供的是跟go自己timer一样的接口,譬如:
func NewTimer(d time.Duration) *Timer
在NewTimer中,参数d是一个time duration,我们还需要根据tick来进行换算,得到go timer中实际的expires,也就是在多少次jiffies后该timer触发。
譬如,NewTimer参数为10s,tick为1s,那么经过10个jiffies之后,该timer就会超时触发。如果tick为500ms,那么需要经过20个jiffies之后,该timer才会被触发。
所以timer超时jiffies的计算如下:
expires = wheel.jiffies + d / wheel.tick
详细的代码在https://github.com/siddontang/golib/tree/master/timer。
相关文章推荐
- golang:一个高性能低精度timer实现
- golang 实现一个restful微服务
- 数字输入golang实现的一个小游戏–猜数字
- c++11 chrono应用 - 一个超时timer的实现
- 请编程实现:产生一个int数组,长度为100,并向其中随机插入1-100,并且不能重复(百度了一下,get一种高性能算法,非递归)
- golang实现的一个扫描指定文件夹下所有中文所在行的小工具
- golang语言实现读取csv文件内容,把相同的内容提取到另外一个文件
- Go语言(golang)快速实现一个bootstrap风格的分页链接
- 再次自我黑客马拉松--不用第三方库实现一个基于golang的web service
- java cache过期策略两种实现,一个基于list轮询一个基于timer定时
- Golang实现一个简单的FTP客户端
- 从零实现一个高性能网络爬虫(一)网络请求分析及代码实现
- 基于HashedWheelTimer的一个定时器实现
- Django中实现一个高性能计数器(Counter)实例
- 一个备份任务分发的Golang实现原型
- Golang中的一个LRU cache实现
- 简单实现一个Unity3d的Timer
- (原创)一个轻量级、高性能的消息分发器的实现
- 统计一个Byte中1的个数,算法尽可能高性能——C++实现
- 一个高性能无锁哈希表的实现