改編為以下腳本：package mainimport (? ? "fmt"? ? "time")func main() {? ? ticker := time.NewTicker(500 * time.Millisecond)? ? done := make(chan bool)? ? go func() {? ? ? ? for {? ? ? ? ? ? select {? ? ? ? ? ? case <-done:? ? ? ? ? ? ? ? fmt.Println("Received 'done'")? ? ? ? ? ? ? ? return? ? ? ? ? ? case t := <-ticker.C:? ? ? ? ? ? ? ? fmt.Println("Tick at", t)? ? ? ? ? ? }? ? ? ? }? ? }()? ? time.Sleep(1600 * time.Millisecond)? ? // ticker.Stop()? ? done <- true? ? // fmt.Println("Ticker stopped.")}與引用示例的兩個區(qū)別是我注釋掉了該ticker.Stop()行并fmt.Println("Received 'done'")在case <-done塊中添加了一行。如果我運行它，我會觀察到以下輸出：> go run tickers.goTick at 2019-10-06 15:25:50.576798 -0700 PDT m=+0.504913907Tick at 2019-10-06 15:25:51.074993 -0700 PDT m=+1.003102855Tick at 2019-10-06 15:25:51.576418 -0700 PDT m=+1.504521538我的問題：為什么它不打印Received 'done'到終端？奇怪的是，如果我在Ticker stoppedPrintln 語句中發(fā)表評論，我也會看到Received 'done'：> go run tickers.goTick at 2019-10-06 15:27:30.735163 -0700 PDT m=+0.504666656Tick at 2019-10-06 15:27:31.234076 -0700 PDT m=+1.003573649Tick at 2019-10-06 15:27:31.735342 -0700 PDT m=+1.504833296Ticker stopped.Received 'done'我記得，Goroutine 中的代碼可以假設(shè)同步運行，所以我很困惑，因為我沒有看到Println前一種情況下語句的效果，因為它發(fā)生在 Goroutine 返回之前。有人可以解釋一下嗎？去并發(fā)性協(xié)程
2 回答
慕森王
TA貢獻(xiàn)1777條經(jīng)驗 獲得超3個贊
發(fā)生時done <- true，main函數(shù)直接返回。
您可以添加另一個 time.Sleep() 來看看發(fā)生了什么。
time.Sleep(1600 * time.Millisecond)
// ticker.Stop()
done <- true
// fmt.Println("Ticker stopped.")
time.Sleep(1600 * time.Millisecond)
SMILET
TA貢獻(xiàn)1796條經(jīng)驗 獲得超4個贊
...為什么它不將 Received 'done' 打印到終端？
它確實這樣做了——或者更確切地說，它嘗試了。
當(dāng)主 goroutine（調(diào)用mainpackage?main）返回時（或者在此處未發(fā)生的各種情況下更早），Go 程序就會退出。您致電并發(fā)送后main返回。time.Sleep()truedone
同時，當(dāng)值到達(dá)通道時，循環(huán)中的 goroutinefor就會被喚醒。這是在主 Goroutine 發(fā)送之后發(fā)生的，之后主 Goroutine 正在退出。truedone
如果在這個退出過程中，主協(xié)程花費的時間足夠長，那么匿名協(xié)程就有時間打印Received 'done'。如果在這個退出過程中，主 Goroutine 足夠快，那么匿名 Goroutine 永遠(yuǎn)不會完成，或者甚至永遠(yuǎn)不會開始，打印任何東西，你什么也看不到。（實際輸出是由單個底層系統(tǒng)調(diào)用完成的，因此您要么獲得全部輸出，要么什么也得不到。）
您可以通過多種機制確保您派生的 goroutine 在主協(xié)程退出之前完成，但最簡單的可能是使用，sync.WaitGroup因為它就是為此設(shè)計的。創(chuàng)建一個 waitgroup，將其計數(shù)器設(shè)置為 1（將 1 添加到其初始零），然后Done在退出匿名 goroutine 時調(diào)用該函數(shù)。讓主協(xié)程等待它。
- 2 回答
- 0 關(guān)注
- 169 瀏覽
添加回答
舉報
0/150
提交
取消