Go 1.23中Timer無(wú)buffer的實(shí)現(xiàn)方式竟是這樣!
在 Go 1.23 中，Timer 的實(shí)現(xiàn)通常是通過(guò) time 包提供的 time.Timer 類型來(lái)實(shí)現(xiàn)的。Timer 是一個(gè)用于在指定時(shí)間后觸發(fā)一次事件的計(jì)時(shí)器。Timer 的實(shí)現(xiàn)并不依賴于緩沖區(qū)，而是通過(guò) Go 的調(diào)度器和通道機(jī)制來(lái)實(shí)現(xiàn)的。
Timer 的基本實(shí)現(xiàn)
Timer 的核心是一個(gè) time.Timer 結(jié)構(gòu)體，它包含一個(gè) time.Timer.C 通道，當(dāng)計(jì)時(shí)器到期時(shí)，當(dāng)前時(shí)間會(huì)被發(fā)送到這個(gè)通道。
以下是一個(gè)簡(jiǎn)單的 Timer 實(shí)現(xiàn)示例：
package main
import (
"fmt"
"time"
)
func main() {
// 創(chuàng)建一個(gè) Timer，設(shè)置 2 秒后觸發(fā)
timer := time.NewTimer(2 * time.Second)
// 等待 Timer 觸發(fā)
<-timer.C
fmt.Println("Timer expired")
// 如果你想要停止 Timer，可以使用 Stop() 方法
// timer.Stop()
}無(wú)緩沖區(qū)的實(shí)現(xiàn)
Timer 的實(shí)現(xiàn)并不依賴于緩沖區(qū)，而是通過(guò) Go 的通道機(jī)制來(lái)實(shí)現(xiàn)的。Timer.C 是一個(gè)無(wú)緩沖的通道，當(dāng)計(jì)時(shí)器到期時(shí)，當(dāng)前時(shí)間會(huì)被發(fā)送到這個(gè)通道。由于通道是無(wú)緩沖的，發(fā)送操作會(huì)阻塞，直到有接收者準(zhǔn)備好接收數(shù)據(jù)。
自定義無(wú)緩沖 Timer 實(shí)現(xiàn)
如果你想自己實(shí)現(xiàn)一個(gè)無(wú)緩沖的 Timer，可以使用 time.After 函數(shù)，它返回一個(gè)通道，當(dāng)指定的時(shí)間到達(dá)時(shí)，通道會(huì)接收到一個(gè)時(shí)間值。
package main
import (
"fmt"
"time"
)
func main() {
// 使用 time.After 創(chuàng)建一個(gè)無(wú)緩沖的 Timer
timerCh := time.After(2 * time.Second)
// 等待 Timer 觸發(fā)
<-timerCh
fmt.Println("Timer expired")
}更復(fù)雜的 Timer 實(shí)現(xiàn)
如果你需要更復(fù)雜的 Timer 實(shí)現(xiàn)，比如可以重置或停止的 Timer，可以參考以下代碼：
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")
}在這個(gè)示例中，MyTimer 是一個(gè)自定義的 Timer 實(shí)現(xiàn)，它支持重置和停止操作。MyTimer 使用 time.Timer 作為底層實(shí)現(xiàn)，并通過(guò)通道來(lái)接收重置和停止的信號(hào)。
總結(jié)
Go 中的 Timer 實(shí)現(xiàn)依賴于無(wú)緩沖的通道和 Go 的調(diào)度器。你可以使用 time.Timer 或 time.After 來(lái)創(chuàng)建簡(jiǎn)單的 Timer，或者通過(guò)自定義結(jié)構(gòu)體來(lái)實(shí)現(xiàn)更復(fù)雜的 Timer 功能。
