我正在嘗試構建一個將通道傳遞給的函數，當在 go 例程中運行時，它會不斷將更新（在本例中為 sin 的值）發布到通道。當數據通過通道發送時，我想通過網絡套接字發送它。func sineWave(value chan float64) { var div float64 sinMult := 6.2839 i := 0 log.Println("started") for { div = (float64(i+1) / sinMult) log.Println(math.Sin(div)) time.Sleep(100 * time.Millisecond) value <- math.Sin(div) // log.Println() i++ if i == 45 { i = 0 } } // log.Println(math.Sin(div * math.Pi))}它似乎卡在value <- main.Sin(div)停止運行 main() 的其余部分。我如何讓 sineWave 在后臺無限期運行并在它們到達時在另一個函數中打印它的輸出？
1 回答
眼眸繁星
TA貢獻1873條經驗 獲得超9個贊
這段代碼有幾個錯誤，
值 chan 永遠不會耗盡，所以任何寫入都會阻塞
價值通道永遠不會關閉，所以任何流失都是無限的
通道必須始終排空，通道必須在某個時刻關閉。
另外，請發布可重現的示例，否則很難診斷問題。
這是 OP 代碼的略微修改但有效的版本。
package main
import (
"fmt"
"math"
"time"
)
func sineWave(value chan float64) {
defer close(value) // A channel must always be closed by the writer.
var div float64
sinMult := 6.2839
i := 0
fmt.Println("started")
for {
div = (float64(i+1) / sinMult)
time.Sleep(100 * time.Millisecond)
value <- math.Sin(div)
i++
if i == 4 {
// i = 0 // commented in order to quit the loop, thus close the channel, thus end the main for loop
break
}
}
}
func main() {
value := make(chan float64)
go sineWave(value) // start writing the values in a different routine
// drain the channel, it will end the loop whe nthe channel is closed
for v := range value {
fmt.Println(v)
}
}
- 1 回答
- 0 關注
- 118 瀏覽
添加回答
舉報
0/150
提交
取消