我正在嘗試構(gòu)建一個(gè)將通道傳遞給的函數(shù)，當(dāng)在 go 例程中運(yùn)行時(shí)，它會(huì)不斷將更新（在本例中為 sin 的值）發(fā)布到通道。當(dāng)數(shù)據(jù)通過通道發(fā)送時(shí)，我想通過網(wǎng)絡(luò)套接字發(fā)送它。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)停止運(yùn)行 main() 的其余部分。我如何讓 sineWave 在后臺(tái)無限期運(yùn)行并在它們到達(dá)時(shí)在另一個(gè)函數(shù)中打印它的輸出？
1 回答
眼眸繁星
TA貢獻(xiàn)1873條經(jīng)驗(yàn) 獲得超9個(gè)贊
這段代碼有幾個(gè)錯(cuò)誤，
值 chan 永遠(yuǎn)不會(huì)耗盡，所以任何寫入都會(huì)阻塞
價(jià)值通道永遠(yuǎn)不會(huì)關(guān)閉，所以任何流失都是無限的
通道必須始終排空，通道必須在某個(gè)時(shí)刻關(guān)閉。
另外，請(qǐng)發(fā)布可重現(xiàn)的示例，否則很難診斷問題。
這是 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 關(guān)注
- 115 瀏覽
添加回答
舉報(bào)
0/150
提交
取消