• Golang开发--计时器(Timer)和定时器(Ticker)


    计时器(Timer)

    在 Go 中,可以使用 time 包提供的计时器(Timer)来执行定时任务。计时器允许你在指定的时间间隔后执行某个操作。
    time.Timer结构表示一个计时器,它会在指定的时间段后触发单次操作。
    创建计时器:使用time.NewTimer(duration)函数创建一个计时器,其中duration是一个time.Duration类型的时间段,表示计时器触发的时间间隔。
    启动计时器:使用timer.Reset(duration)方法来启动或重新启动计时器,计时器会在之后的指定时间间隔后触发。
    等待计时器触发:使用<-timer.C语法来等待计时器触发,该语句会阻塞当前的goroutine,直到计时器触发。
    停止计时器:使用timer.Stop()方法来停止计时器,防止计时器触发。

    package main
    
    import (
    	"fmt"
    	"time"
    )
    
    func main() {
    	// 创建一个计时器,每隔 2 秒触发一次
    	timer := time.NewTimer(2 * time.Second)
    
    	// 使用匿名函数作为任务函数
    	task := func() {
    		fmt.Println("定时任务执行")
    	}
    
    	// 在单独的 Goroutine 中执行定时任务
    	go func() {
    		for {
    			<-timer.C  // 从计时器的通道中读取时间到达的信号
    			task()     // 执行定时任务
    			timer.Reset(2 * time.Second)  // 重置计时器,以便下次触发
    		}
    	}()
    
    	// 主 Goroutine 持续执行其他操作
    	for {
    		// 这里可以执行其他任务
    		time.Sleep(1 * time.Second)
    	}
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31

    在上面的代码中,我们首先创建了一个计时器 timer,使用 time.NewTimer() 函数并传入时间间隔参数来初始化。然后,我们定义了一个任务函数 task(),它将在计时器触发时执行。

    接下来,我们在一个单独的 Goroutine 中使用无限循环来等待计时器的信号。通过 <-timer.C 语句,我们从计时器的通道中读取到达的信号,然后执行任务函数。在任务执行后,我们使用 timer.Reset() 函数重置计时器,以便下次触发。

    在主 Goroutine 中,我们可以执行其他操作。在这个示例中,我们使用 time.Sleep() 函数来模拟其他任务的执行。

    需要注意的是,如果想停止定时任务,可以调用 timer.Stop() 函数来停止计时器。

    定时器(Ticker)

    time.Ticker结构表示一个定时器,它会定期触发操作,类似于循环计时器。
    创建定时器:使用time.NewTicker(duration)函数创建一个定时器,其中duration是一个time.Duration类型的时间段,表示定时器触发的时间间隔。
    启动定时器:定时器会自动开始触发,无需手动启动。
    定时触发操作:使用<-ticker.C语法来等待定时器触发,每次触发都会向通道发送一个时间值。
    停止定时器:使用ticker.Stop()方法来停止定时器的触发。
    示例代码:

    import (
        "fmt"
        "time"
    )
    
    func main() {
        ticker := time.NewTicker(1 * time.Second)
    
        go func() {
            for {
                <-ticker.C // 等待定时器触发
                fmt.Println("定时器触发")
            }
        }()
    
        time.Sleep(5 * time.Second)
        ticker.Stop() // 停止定时器触发
        fmt.Println("定时器停止")
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19

    以上示例中,计时器会在2秒后触发,而定时器会每秒触发一次,直到被停止。在实际应用中,可以根据需要在计时器或定时器触发时执行相应的操作,例如定期执行某个函数、定时检查状态、定时发送心跳等。

    需要注意的是,如果在计时器触发前停止计时器或关闭接收通道,可能会导致资源泄漏或死锁等问题,因此在使用计时器和定时器时务必小心处理。

  • 相关阅读:
    2021年下半年信息安全工程师上午真题及答案解析
    Nginx设置Https
    java毕业设计宠物商城网站系统Mybatis+系统+数据库+调试部署
    第5章 泛型服务的定义实现
    群晖synology DSM 7.2设置钉钉Webhooks通知
    JAVA学习-三元操作符if-else
    数据库事务相关知识点
    TCP Window Full & TCP Zero Window
    快速排序及优化
    JVM运行时数据区域详解
  • 原文地址:https://blog.csdn.net/liulanba/article/details/132886309