在 Go 1.23 中，Timer 的实现通常是通过 time 包提供的 time.Timer 类型来实现的。Timer 是一个用于在指定时间后触发一次事件的计时器。Timer 的实现并不依赖于缓冲区，而是通过 Go 的调度器和通道机制来实现的。
Timer 的基本实现
Timer 的核心是一个 time.Timer 结构体，它包含一个 time.Timer.C 通道，当计时器到期时，当前时间会被发送到这个通道。
以下是一个简单的 Timer 实现示例：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
package main
import ( "fmt" "time" )
func main() { // 创建一个 Timer，设置 2 秒后触发 timer := time.NewTimer(2 * time.Second)
// 等待 Timer 触发 <-timer.C fmt.Println("Timer expired")
// 如果你想要停止 Timer，可以使用 Stop() 方法 // timer.Stop() } |
无缓冲区的实现
Timer 的实现并不依赖于缓冲区，而是通过 Go 的通道机制来实现的。Timer.C 是一个无缓冲的通道，当计时器到期时，当前时间会被发送到这个通道。由于通道是无缓冲的，发送操作会阻塞，直到有接收者准备好接收数据。
自定义无缓冲 Timer 实现
如果你想自己实现一个无缓冲的 Timer，可以使用 time.After 函数，它返回一个通道，当指定的时间到达时，通道会接收到一个时间值。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
package main
import ( "fmt" "time" )
func main() { // 使用 time.After 创建一个无缓冲的 Timer timerCh := time.After(2 * time.Second)
// 等待 Timer 触发 <-timerCh fmt.Println("Timer expired") } |
更复杂的 Timer 实现
如果你需要更复杂的 Timer 实现，比如可以重置或停止的 Timer，可以参考以下代码：
|
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 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
package main
import ( "fmt" "time" )
type MyTimer struct { duration time.Duration timer *time.Timer resetCh chan time.Duration stopCh chan struct{} }
func NewMyTimer(duration time.Duration) *MyTimer { t := &MyTimer{ duration: duration, resetCh: make(chan time.Duration), stopCh: make(chan struct{}), } t.timer = time.NewTimer(duration) go t.run() return t }
func (t *MyTimer) run() { for { select { case <-t.timer.C: fmt.Println("Timer expired") return case newDuration := <-t.resetCh: if !t.timer.Stop() { <-t.timer.C } t.timer.Reset(newDuration) case <-t.stopCh: if !t.timer.Stop() { <-t.timer.C } return } } }
func (t *MyTimer) Reset(duration time.Duration) { t.resetCh <- duration }
func (t *MyTimer) Stop() { t.stopCh <- struct{}{} }
func main() { timer := NewMyTimer(2 * time.Second)
time.Sleep(1 * time.Second) timer.Reset(3 * time.Second)
time.Sleep(2 * time.Second) timer.Stop() fmt.Println("Timer stopped") } |
在这个示例中，MyTimer 是一个自定义的 Timer 实现，它支持重置和停止操作。MyTimer 使用 time.Timer 作为底层实现，并通过通道来接收重置和停止的信号。
总结
Go 中的 Timer 实现依赖于无缓冲的通道和 Go 的调度器。你可以使用 time.Timer 或 time.After 来创建简单的 Timer，或者通过自定义结构体来实现更复杂的 Timer 功能。
