在Golang中同时从多个通道读取

我是Golang的新手。现在,我正在尝试找出如何在Golang中建立任意一对一频道的方法,其设置如下:

说我有两个goroutines numgen1和numgen2同时执行并将数字写入通道num1resp。num2。我想在新进程addnum中添加从numgen1和numgen2发送的数字。我已经尝试过这样的事情:

func addnum(num1, num2, sum chan int) {

done := make(chan bool)

go func() {

n1 := <- num1

done <- true

}()

n2 := <- num2

<- done

sum <- n1 + n2

}

但这似乎令人遗憾。有人可以给我一些想法吗?

非常感谢您的帮助。

回答:

根据您的要求,您可能需要为每次迭代读取 两个 通道(即某种“zip”功能)

func main() {

c1 := make(chan int)

c2 := make(chan int)

out := make(chan int)

go func(in1, in2 <-chan int, out chan<- int) {

for {

sum := 0

select {

case sum = <-in1:

sum += <-in2

case sum = <-in2:

sum += <-in1

}

out <- sum

}

}(c1, c2, out)

}

这将永远运行。我终止此类goroutine的首选方法是关闭输入通道。在这种情况下,您需要等待两者都关闭,然后close(out)再终止。

提示:请注意使用定向通道作为goroutine形式参数。这样编写时,编译器会遇到更多错误。幸福!

以上是 在Golang中同时从多个通道读取 的全部内容, 来源链接: utcz.com/qa/417788.html

回到顶部