我正在學習 GO 中的通道和并發性，但我被困在一項任務中。我想要傳遞一個切片、過濾數字然后打印通道值的函數。問題是，當我使用頻道時，它會使程序陷入僵局。這是我的代碼：package mainimport ( "fmt")func processOdd(inputs []int) chan int { oddValues := make(chan int) for _, numbers := range inputs { go func(num int) { if num%2 != 0 { oddValues <- num } }(numbers) } return oddValues}func processEven(inputs []int) chan int { evenValues := make(chan int) for _, numbers := range inputs { go func(num int) { if num%2 == 0 { evenValues <- num } }(numbers) } return evenValues}func main() { inputs := []int{1, 17, 34, 56, 2, 8} evenCH := processEven(inputs) for range inputs { fmt.Print(<-evenCH) }}
1 回答
HUH函數
TA貢獻1836條經驗 獲得超4個贊
完成發送值后關閉通道：
func processEven(inputs []int) chan int {
evenValues := make(chan int)
var wg sync.WaitGroup
for _, num := range inputs {
wg.Add(1)
go func(num int) {
defer wg.Done()
if num%2 == 0 {
evenValues <- num
}
}(num)
}
go func() {
wg.Wait()
close(evenValues)
}()
return evenValues
}
該代碼使用WaitGroup來等待發送者完成。
循環接收值直到通道關閉：
func main() {
inputs := []int{1, 17, 34, 56, 2, 8}
evenCh := processEven(inputs)
for num := range evenCh {
fmt.Println(num)
}
}
通道上的范圍循環，直到通道關閉。
- 1 回答
- 0 關注
- 100 瀏覽
添加回答
舉報
0/150
提交
取消