我有一個類似于以下程序的程序：package mainimport ( "fmt" "time")func main() { ch := make(chan string) go endProgram(ch) printFunc(ch)}func printFunc(ch chan string) { for { timeout := time.NewTimer(getTimeoutDuration()) defer timeout.Stop() select { case s := <-ch: fmt.Println(s) return case <-timeout.C: fmt.Println("Current value") } }}func endProgram(ch chan string) { time.Sleep(time.Second * 8) ch <- "Exit function"}func getTimeoutDuration() time.Duration { return time.Second * 3}在這種情況下，停止計時器的最佳方法是什么？timeout我知道上面不是推薦的方法，因為使用for loop內部的延遲是一種不好的做法。另一種方法是在for循環中使用，而不是因為我們不必停止。但如果函數在計時器觸發（源）之前退出，則會導致資源泄漏。time.Aftertime.NewTimertime.Aftertime.After
1 回答
Smart貓小萌
TA貢獻1911條經驗 獲得超7個贊
如果使用上下文而不是計時器，則僅在退出函數大小寫條件時調用取消。
package main
import (
"context"
"fmt"
"time"
)
func main() {
ch := make(chan string)
go endProgram(ch)
printFunc(ch)
}
func printFunc(ch chan string) {
for {
ctx, cancel := context.WithTimeout(context.Background(), getTimeoutDuration())
select {
case s := <-ch:
cancel()
fmt.Println(s)
return
case <-ctx.Done():
fmt.Println("Current value")
}
}
}
func endProgram(ch chan string) {
time.Sleep(time.Second * 8)
ch <- "Exit function"
}
func getTimeoutDuration() time.Duration {
return time.Second * 3
}
添加回答
舉報
0/150
提交
取消