一文带你探索Golang计时器的奥秘
作者:金刀大菜牙 发布时间:2024-02-17 22:35:37
Golang 是一种简洁高效的编程语言,拥有强大的并发支持和丰富的标准库。在 Golang 中,计时器(timer)是一种常见的工具,用于定期执行某个任务或者在指定时间后触发某个事件。本文将深入探讨 Golang 计时器的实现原理和使用方法,帮助大家更好地理解和应用计时器。
1. Golang 计时器基础
在开始之前,我们需要了解 Golang 中计时器的基本概念和使用方法。
1.1 计时器的创建和启动
在 Golang 中,计时器可以通过 time.NewTimer(d Duration) *Timer 方法来创建,其中 d 参数表示计时器的触发时间间隔。计时器创建后需要调用 timer.Start() 方法来启动计时器。
package main
import (
"fmt"
"time"
)
func main() {
timer := time.NewTimer(1 * time.Second)
timer.Start()
// 其他逻辑代码
<-timer.C
fmt.Println("计时器触发")
}
1.2 计时器的停止
通过 timer.Stop() 方法可以停止计时器的运行。如果在计时器触发之前调用了 timer.Stop() 方法,那么计时器将被停止,不会触发事件。
package main
import (
"fmt"
"time"
)
func main() {
timer := time.NewTimer(1 * time.Second)
timer.Start()
// 其他逻辑代码
timer.Stop()
fmt.Println("计时器已停止")
}
1.3 计时器的重置
计时器可以通过 timer.Reset(d Duration) bool 方法来重置计时器的触发时间间隔。该方法返回一个布尔值,表示计时器是否成功重置。
package main
import (
"fmt"
"time"
)
func main() {
timer := time.NewTimer(1 * time.Second)
timer.Start()
// 其他逻辑代码
timer.Reset(2 * time.Second)
fmt.Println("计时器已重置")
}
2. Golang 计时器实现原理
了解了计时器的基本使用方法后,我们来深入探讨 Golang 计时器的实现原理。Golang 的计时器是基于堆的实现,通过调整堆中元素的顺序来确定最近的触发时间。
2.1 堆结构
Golang 的堆(heap)是一种完全二叉树的数据结构,其中每个节点的值都大于或等于其子节点的值。在堆中,根节点的值最小(或最大),因此也称为最小堆(或最大堆)。
2.2 计时器的堆实现
当我们创建一个计时器时,Golang 内部会创建一个计时器对象(Timer)。该计时器对象包含以下字段:
when:表示计时器的触发时间,以纳秒为单位。
period:表示计时器的触发间隔,以纳秒为单位。
f:表示计时器触发时要执行的函数。
arg:表示传递给计时器触发函数的参数。
seq:表示计时器的序号。
Golang 使用一个全局的计时器堆(timerHeap)来管理所有的计时器对象。该堆是一个切片,其中每个元素都是一个计时器对象的指针。
当我们创建并启动一个计时器时,计时器对象会被添加到计时器堆中,并根据触发时间进行调整,以确保堆的顶部元素是最近要触发的计时器。
在计时器触发的时刻,Golang 会从计时器堆中取出堆顶的计时器对象,并执行其触发函数。随后,如果计时器是周期性的,则会根据触发间隔重新计算下一次触发时间,并将计时器对象再次插入堆中。
2.3 计时器的堆调整
当我们启动计时器、重置计时器或者停止计时器时,计时器堆需要进行相应的调整,以保持堆的性质。
启动计时器:将计时器对象插入堆中,并根据触发时间进行调整。
重置计时器:首先将计时器对象从堆中移除,然后更新触发时间和周期,并重新插入堆中进行调整。
停止计时器:将计时器对象从堆中移除。
Golang 的计时器堆实现了 container/heap 接口,通过调用 heap.Init(h *timerHeap)、eap.Push(h *timerHeap, x interface{}) 和 heap.Pop(h *timerHeap) interface{} 等方法,可以方便地对计时器堆进行初始化、插入和删除操作。
3. Golang 计时器的高级用法
除了基本的使用方法,Golang 计时器还提供了一些高级的用法,可以更灵活地应用计时器。
3.1 计时器的单次触发
默认情况下,Golang 的计时器是周期性的,即在触发后会根据设定的触发间隔再次触发。如果我们只需要计时器触发一次,则可以在触发函数中手动停止计时器。
package main
import (
"fmt"
"time"
)
func main() {
timer := time.NewTimer(1 * time.Second)
timer.Start()
go func() {
<-timer.C
fmt.Println("计时器触发")
timer. Stop()
}()
// 其他逻辑代码
time.Sleep(2 * time.Second) // 等待计时器触发或超时
}
在上面的示例中,我们在匿名的 goroutine 中等待计时器触发,并在触发后手动调用 timer.Stop() 方法停止计时器。这样,计时器只会触发一次。
3.2 计时器的超时控制
有时候我们需要在一定的时间范围内执行某个操作,如果超过了指定的时间仍未完成,则需要进行超时处理。Golang 的计时器可以很好地支持这种场景。
package main
import (
"fmt"
"time"
)
func main() {
timeout := 3 * time.Second
done := make(chan bool)
go func() {
// 模拟一个耗时操作
time.Sleep(2 * time.Second)
done <- true
}()
select {
case <-done:
fmt.Println("操作完成")
case <-time.After(timeout):
fmt.Println("操作超时")
}
}
在上面的示例中,我们使用 time.After(timeout) 创建了一个计时器,当超过指定的超时时间后,该计时器会触发,从而触发超时处理逻辑。
3.3 计时器的延迟执行
有时候我们希望在一定的延迟时间后执行某个操作。Golang 的计时器可以帮助我们实现这个需求。
package main
import (
"fmt"
"time"
)
func main() {
delay := 2 * time.Second
timer := time.NewTimer(delay)
go func() {
<-timer.C
fmt.Println("延迟执行")
}()
// 其他逻辑代码
time.Sleep(3 * time.Second) // 等待计时器触发或超时
}
在上面的示例中,我们创建了一个计时器,并在匿名的 goroutine 中等待计时器触发。通过调整计时器的延迟时间,可以灵活控制操作的延迟执行。
4. 总结
本文深入探讨了 Golang 计时器的实现原理和使用方法。我们了解了计时器的基本概念和操作方法,以及计时器堆的实现原理。此外,还介绍了计时器的单次触发、超时控制和延迟执行等高级用法。通过学习和应用这些知识,我们可以更好地理解和使用 Golang 的计时器,为大家提供精确的定时触发和调度功能。希望本文能对大家在 Golang 计时器的学习和实践中起到指导和帮助作用。
来源:https://juejin.cn/post/7230728447207030842
猜你喜欢
- sys.argv[]说白了就是一个从程序外部获取参数的桥梁,这个“外部”很关键,因为我们从外部取得的参数可以是多个,所以获得的是一个列表(l
- 元数据简介元数据 (metadata) 最常见的定义为“有关数据的结构数据”,或者再简单一点就是“关于数据的信息”,日常生活中的图例、图书馆
- 1、ValueError: Invalid control character at: line 1 column 8363 (char 8
- 一段非常简单代码普通调用方式def console1(a, b): print("进入函数")
- 主要讲 except 和 not in 的性能上的区别。 代码如下:CREATE TABLE tb1(ID int) CREAT
- 使用access数据库时可能用到的数据转换:类型转换涵数:函数 返回类型 expression 参数范围CBool Boolean 任何有效
- a=1 #1 为对象,def func(x): print('x的地址{}'.form
- 一.实现思路本文讲解如何使用python实现一个简单的模板引擎, 支持传入变量, 使用if判断和for循环语句, 最终能达到下面这样的效果:
- 本文实例讲述了Python3.6基于正则实现的计算器。分享给大家供大家参考,具体如下:# -*- coding:utf-8 -*-#!pyt
- 一、破解原理其实原理很简单,一句话概括就是「大力出奇迹」,Python 有两个压缩文件库:zipfile 和 rarfile,这两个库提供的
- <div id="d1"></div> <script > fu
- http通过StreamingHttpResponse完成连续的数据传输长链接问题http服务之间传递结果流一个由flask封装起来的算法,
- 本文介绍了Python对于线程的支持,包括“学会”多线程编程需要掌握的基础以及Python两个线程标准库的完整介绍及使用示例。注意:本文基于
- 最近在处理Qzone黄钻图标更新时,想起近期对业务图标进行优化所遇到的一些问题,把思绪收拾起来和大家一共探讨,欢迎多方声音。在实际工作中,图
- 说起 Python 强大的地方,你可能想到是它的优雅、简洁、开发速度快,社区活跃度高。但真正使得这门语言经久不衰的一个重要原因是它的无所不能
- 我正在开发一个档案管理系统,需要从数据库中同时调出图像及相关的文字说明,可我只做到了单纯地显示图片,像有一个数据库CHUNFENG,在数据库
- 本文实例为大家分享了python实现多张图片拼接成大图的具体代码,供大家参考,具体内容如下上次爬取了马蜂窝的游记图片,并解决了PIL模块的导
- 0x00 前言eval是Python用于执行python表达式的一个内置函数,使用eval,可以很方便的将字符串动态执行。比如下列代码:&g
- 在安装mysqlclient的时候出现了以下报错:解决办法:1.到提示网址:https://visualstudio.microsoft.c
- 目录1、系统环境,必要知识2、安装python3.6.53、安装Django4、安装uWSGI5、安装nginx6、MySQL安装配置7、编