掌握 Go 的计时器

简介: 掌握 Go 的计时器

简介


定时器是任何编程语言的重要工具,它允许开发人员在特定时间间隔安排任务或执行代码。在 Go 中,定时器是通过 time 包实现的,该包提供了一系列功能来创建、启动、停止和有效处理定时器。我们将探索 Go 中定时器的强大功能,并通过代码示例演示如何在应用程序中使用定时器。


创建计时器


要在 Go 中创建一个定时器,我们可以使用 time.NewTimer() 函数,该函数将持续时间作为参数。下面是一个示例:

func CreateTimer() {
 timer := time.NewTimer(2 * time.Second)
 fmt.Println("Timer created.")
 <-timer.C // 阻塞
 fmt.Println("Timer expired.")
}


在上述代码片段中,我们使用 time.NewTimer() 创建了一个持续时间为 2 秒的新定时器。<-timer.C 语句会阻塞执行,直到定时器过期。定时器到期后,"Timer expired."(定时器已过期)信息将打印到控制台。


停止计时器


在某些情况下,您可能想在定时器到期前停止它。为此,您可以使用定时器对象的 Stop() 方法。让我们修改之前的示例,加入定时器停止功能:

func StopTimer() {
 timer := time.NewTimer(2 * time.Second)
 fmt.Println("Timer created.")
 go func() {
  <-timer.C
  fmt.Println("Timer expired.")
 }()
 time.Sleep(1 * time.Second)
 stopped := timer.Stop()
 if stopped {
  fmt.Println("Timer stopped.")
 } else {
  fmt.Println("Timer has already expired.")
 }
}


在更新后的代码中,我们创建了一个 goroutine 来处理定时器过期,这样就可以在定时器过期前停止它。我们使用 time.Sleep() 函数来模拟在尝试停止计时器之前正在进行的一些工作。最后,我们调用 timer.Stop() 停止定时器。如果定时器已过期,timer.Stop() 返回 false,并打印 "定时器已过期"。否则,我们将打印 "定时器已停止"。


重置计时器


Go 还提供了重置活动定时器的方法。通过 Reset() 方法,您可以更改活动定时器的持续时间,重新开始倒计时。下面是一个示例:


func ResetTimer() {
 timer := time.NewTimer(10 * time.Second)
 fmt.Printf("time: %d, Timer created.\n", time.Now().Unix())
 time.Sleep(2 * time.Second)
 reset := timer.Reset(3 * time.Second)
 if reset {
  fmt.Printf("time: %d, Timer reset.\n", time.Now().Unix())
 } else {
  fmt.Printf("time: %d, Timer has already expired.\n", time.Now().Unix())
 }
 <-timer.C // 阻塞
 fmt.Printf("time: %d, Timer expired again.\n", time.Now().Unix())
}


输出为:


time: 1695183503, Timer created.
time: 1695183505, Timer reset.
time: 1695183508, Timer expired again.


在上述代码中,我们创建了一个持续时间为 10 秒的计时器。使用 time.Sleep() 等待 2 秒后,我们调用 timer.Reset(),新的持续时间为 3 秒。如果定时器尚未过期,则重置操作成功,我们将打印 "定时器重置"。否则,进入到 <-timer.C 阻塞阶段,然后打印 我们将打印 "Timer expired again."。


重置定时器与停止定时器


了解重置定时器和使用 Stop() 停止定时器之间的区别非常重要。

func CompareResetAndStop() {
 timer := time.NewTimer(5 * time.Second)
 fmt.Printf("time: %d, Timer created.\n", time.Now().Unix())
 go func() {
  <-timer.C
  fmt.Printf("time: %d, Timer expired.\n", time.Now().Unix())
 }()
 time.Sleep(2 * time.Second)
 timer.Reset(3 * time.Second)
 fmt.Printf("time: %d, Timer reset.\n", time.Now().Unix())
 time.Sleep(2 * time.Second)
 timer.Stop()
 fmt.Printf("time: %d, Timer stopped.\n", time.Now().Unix())
}


输出为:


time: 1695183802, Timer created.
time: 1695183804, Timer reset.
time: 1695183806, Timer stopped.

在本例中,我们创建了一个持续时间为 5 秒的计时器。2 秒后,我们使用 timer.Reset() 将计时器重置为 3 秒。之后,再过 2 秒,我们使用 timer.Stop() 停止计时器。重置定时器会改变其持续时间并重新开始倒计时,而停止定时器则会立即停止执行,无论剩余持续时间多长。


带 Ticker 的计时器

Go 提供了一种 Ticker 类型,它是一种专门的定时器,可在指定的时间间隔内重复触发。定时器可用于定期执行任务。

func Tick() {
 ticker := time.NewTicker(1 * time.Second)
 defer ticker.Stop()
 go func() {
  for range ticker.C {
   fmt.Printf("time: %d, Ticker ticked!\n", time.Now().Unix())
  }
 }()
 time.Sleep(5 * time.Second)
}


在本例中,我们使用 time.NewTicker() 创建了一个持续时间为 1 秒的 Ticker。然后,我们启动一个 goroutine,从 ticker.C channel 接收值,每当滴答声响起时,goroutine 就会发出一个值。在 goroutine 中,每次接收到一个 tick 时,我们都会打印 "Ticker ticked!"。调用 time.Sleep() 可以让滴答滴答运行 5 秒钟,然后退出程序。


使用 Select 的超时


Go 的 select 语句允许在多个通道上执行非阻塞操作。这可以用来使用计时器实现超时。

func TimeOut() {
 ch := make(chan string)
 go func() {
  time.Sleep(2 * time.Second)
  ch <- "Operation completed."
 }()
 select {
 case msg := <-ch:
  fmt.Println(msg)
 case <-time.After(1 * time.Second):
  fmt.Println("Timeout reached.")
 }
}


在本例中,我们创建了一个 channel ch,并启动一个 goroutine 来模拟耗时 2 秒的操作。我们使用 select 语句从 ch 接收信息,或使用 time.After() 等待超时。如果操作在 1 秒内完成,则打印消息。否则,将执行超时情况,并打印 "Timeout reached."。

相关文章
|
缓存 监控 Go
Go 语言入门很简单:Go 计时器
一般来说,很多时候我们面临这样一种情况,即我们需要运行时间记录器,它不断向我们显示当前时间或在给定的时间间隔内保持执行一定的代码和平,在这种情况下,我们应该使用 Ticker,使用这个我们需要使用 go 语言的 time 包,我们有一个名为 NewTicker() 的方法,它允许我们停止和启动时间代码,我们需要通过传递 chan 和 bool 作为将使用的参数来创建一个代码通道检查它是否打开,如果通道打开意味着计时器将继续。
|
6天前
|
存储 JSON 监控
Viper,一个Go语言配置管理神器!
Viper 是一个功能强大的 Go 语言配置管理库,支持从多种来源读取配置,包括文件、环境变量、远程配置中心等。本文详细介绍了 Viper 的核心特性和使用方法,包括从本地 YAML 文件和 Consul 远程配置中心读取配置的示例。Viper 的多来源配置、动态配置和轻松集成特性使其成为管理复杂应用配置的理想选择。
23 2
|
10天前
|
JavaScript Java Go
探索Go语言在微服务架构中的优势
在微服务架构的浪潮中,Go语言以其简洁、高效和并发处理能力脱颖而出。本文将深入探讨Go语言在构建微服务时的性能优势,包括其在内存管理、网络编程、并发模型以及工具链支持方面的特点。通过对比其他流行语言,我们将揭示Go语言如何成为微服务架构中的一股清流。
102 53
|
4天前
|
Go 索引
go语言中的循环语句
【11月更文挑战第4天】
13 2
|
4天前
|
Go C++
go语言中的条件语句
【11月更文挑战第4天】
16 2
|
9天前
|
Ubuntu 编译器 Linux
go语言中SQLite3驱动安装
【11月更文挑战第2天】
31 7
|
9天前
|
关系型数据库 Go 网络安全
go语言中PostgreSQL驱动安装
【11月更文挑战第2天】
38 5
|
9天前
|
安全 Go
用 Zap 轻松搞定 Go 语言中的结构化日志
在现代应用程序开发中,日志记录至关重要。Go 语言中有许多日志库,而 Zap 因其高性能和灵活性脱颖而出。本文详细介绍如何在 Go 项目中使用 Zap 进行结构化日志记录,并展示如何定制日志输出,满足生产环境需求。通过基础示例、SugaredLogger 的便捷使用以及自定义日志配置,帮助你在实际开发中高效管理日志。
25 1
|
8天前
|
程序员 Go
go语言中的控制结构
【11月更文挑战第3天】
85 58
|
7天前
|
监控 Go API
Go语言在微服务架构中的应用实践
在微服务架构的浪潮中,Go语言以其简洁、高效和并发处理能力脱颖而出,成为构建微服务的理想选择。本文将探讨Go语言在微服务架构中的应用实践,包括Go语言的特性如何适应微服务架构的需求,以及在实际开发中如何利用Go语言的特性来提高服务的性能和可维护性。我们将通过一个具体的案例分析,展示Go语言在微服务开发中的优势,并讨论在实际应用中可能遇到的挑战和解决方案。