速率限制

Posted on Updated on 
package main
 
import (
    "fmt"
    "time"
)
 
func main() {
    ticker := time.NewTicker(1 * time.Second) // 设置速率限制
    defer ticker.Stop()
 
    go func() {
        for range ticker.C {
            fmt.Println("Tick: Doing work...")
            // 在这里执行工作
        }
    }()
 
    // 模拟工作5秒
    time.Sleep(5 * time.Second)
}

解释这一段代码执行流程

这段代码展示了如何使用 Go 语言中的 `time.Ticker` 来实现定时任务。以下是代码的详细执行流程解释：

—

### 1. 导入包

“`go
import (
“fmt”
“time”
)
“`
– `fmt` 包用于格式化输出。
– `time` 包用于处理时间相关的操作，如定时器和休眠。

—

### 2. `main` 函数

func main() {
    ticker := time.NewTicker(1 * time.Second) // 设置速率限制
    defer ticker.Stop()
 
    go func() {
        for range ticker.C {
            fmt.Println("Tick: Doing work...")
            // 在这里执行工作
        }
    }()
 
    // 模拟工作5秒
    time.Sleep(5 * time.Second)
}

#### 代码执行流程：
1. **创建 `Ticker`**

   ticker := time.NewTicker(1 * time.Second)

– 使用 `time.NewTicker` 创建一个 `Ticker`，它会每隔 1 秒向 `ticker.C` 通道发送一个时间值。
– `ticker.C` 是一个通道（`chan time.Time`），用于接收定时器触发的事件。

2. **延迟关闭 `Ticker`**

   defer ticker.Stop()

– 使用 `defer` 确保在 `main` 函数退出时调用 `ticker.Stop()`，停止 `Ticker` 并释放相关资源。

3. **启动 goroutine 执行定时任务**

   go func() {
       for range ticker.C {
           fmt.Println("Tick: Doing work...")
           // 在这里执行工作
       }
   }()

– 启动一个匿名 goroutine，监听 `ticker.C` 通道。
– 每当 `ticker.C` 接收到一个时间值（即每隔 1 秒），就会执行一次循环体：
– 打印 `”Tick: Doing work…”`。
– 可以在注释的位置 `// 在这里执行工作` 添加具体的任务逻辑。

4. **主 goroutine 休眠 5 秒**

   time.Sleep(5 * time.Second)

– 主 goroutine 休眠 5 秒，模拟程序运行一段时间。
– 在这 5 秒内，`Ticker` 会触发 5 次（每秒一次），因此 goroutine 会打印 5 次 `”Tick: Doing work…”`。

5. **程序退出**
– 当主 goroutine 的 `time.Sleep(5 * time.Second)` 结束后，`main` 函数退出。
– 由于 `defer ticker.Stop()` 的存在，`Ticker` 会被停止，释放相关资源。
– goroutine 中的 `for range ticker.C` 循环也会因为 `ticker.C` 通道关闭而退出。

—

### 3. 代码输出
在 5 秒内，`Ticker` 会触发 5 次，因此程序会输出：
“`
Tick: Doing work…
Tick: Doing work…
Tick: Doing work…
Tick: Doing work…
Tick: Doing work…
“`

—

### 4. 总结
– **`time.Ticker`** 用于实现定时任务，每隔指定的时间间隔触发一次。
– **`ticker.C`** 是一个通道，用于接收定时器触发的事件。
– **`defer ticker.Stop()`** 确保在程序退出时停止 `Ticker`，避免资源泄漏。
– **`for range ticker.C`** 用于监听 `Ticker` 的触发事件，并执行相应的任务。
– 主 goroutine 休眠 5 秒，模拟程序运行一段时间，期间 `Ticker` 会触发 5 次。

这段代码是一个典型的定时任务实现，适用于需要周期性执行任务的场景。

Post Views: 72