很抱歉这个菜鸟问题,但我很难把头放在 go 的并发部分。基本上,下面的这个程序是我正在编写的一个更大的程序的简化版本,因此我想保持类似于下面的结构。
基本上,我想addCount(..)
使用无缓冲通道并发运行而不是等待 4 秒,并且当 中的所有元素int_slice
都被处理后,我想对它们进行另一个操作。然而,这个程序以“恐慌:关闭通道关闭”结束,如果我取消关闭通道,我会得到我期待的输出,但它会恐慌:“致命错误:所有 goroutines 都睡着了 - 死锁”
在这种情况下如何正确实现并发部分?
提前致谢!
package main
import (
"fmt"
"time"
)
func addCount(num int, counter chan<- int) {
time.Sleep(time.Second * 2)
counter <- num * 2
}
func main() {
counter := make(chan int)
int_slice := []int{2, 4}
for _, item := range int_slice {
go addCount(item, counter)
close(counter)
}
for item := range counter {
fmt.Println(item)
}
}
Run Code Online (Sandbox Code Playgroud)