2 回答

TA貢獻1906條經驗 獲得超10個贊
有些代碼路徑不會打印某些done消息。調度程序碰巧選擇了一個不為multiply. 如果您稍微更改代碼(例如,在與現在不同的實例上登錄),您會發現它也可能會丟失add done消息。(https://play.golang.org/p/meEPM5GR9Rr)。原因如下:
如果done消息在生成器將數字寫入通道并且乘法器讀取它之后立即到達,那么乘法器會看到done可用并選擇它。multiplier打印done消息時就是這種情況。如果done消息在 multiplier 在 for 循環中等待時到達,則 multiplier 將接收輸入通道(而不是done通道)的關閉,導致 for 循環終止而不打印done消息。
出現問題是因為您正在從 for 循環中的通道讀取,然后進行選擇。在等待 for 循環從通道中讀取數據時,不會評估與選擇相關的任何事件。
解決這個問題的更好方法是不使用 for 循環從通道中讀取。例如:
for {
select {
case <-done:
return
case i, ok:= <-intstream:
if !ok {
return
}
select {
case <- done:
return
case addedStream <- i + additive:
}
}
}

TA貢獻1789條經驗 獲得超8個贊
你的add和multiply例程不是永遠的循環,而是for ... range循環。因此,在每個循環的頂部,它們等待下一個整數,而不是等待select接收關閉done或將結果發送到它們的流。這不是問題,但這意味著如果它們的輸入流關閉,它們將返回而不進入循環本身。
如果我添加fmt.Println調用以暴露由于到達輸入流的末尾而退出的點,則行為會略有變化(可能是由于時間的原因;我沒有費心去解釋它,而Burak Serdar已經發布了他的答案我正在輸入這個),輸出變為:
add after select
2
multiply after select
generator after select
multiply after select
add after select
4
generator after select
multiply after select
add after select
6
generator after select
Closed done
done multiply !
add got end of stream - done!
finished iterating pipeline
generator after select
done generator!
ramaining goroutines: 1
finished!
通常更合理的是只讓生成器本身接收done信號,并使流水線函數始終寫入所有結果,這使得它們更可預測。當然,讀取每個管道的人必須讀到最后——但你已經在主 goroutine 中這樣做了,所以我們只是在整個過程中傳播它。 這是以這種方式執行的代碼的簡化版本;它輸出:
2
generator after select
4
generator after select
6
generator after select
Closed done
8
generator after select
done generator!
multiply got end of stream - done!
add got end of stream - done!
finished iterating pipeline
remaining goroutines: 1
請注意,這一次,我們從最終生成的值 (3) 中得到最終的計算值 (8)。
- 2 回答
- 0 關注
- 158 瀏覽
添加回答
舉報