我正在学习 Go,并且遇到了以下代码片段:
package main
import "fmt"
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
c <- sum // send sum to c
}
func main() {
a := []int{7, 2, 8, -9, 4, 0}
c := make(chan int, 2)
go sum(a[0:3], c)
go sum(a[3:6], c)
x := <-c
y := <-c
// x, y := <-c, <-c // receive from c
fmt.Println(x, y)
}
Output:
-5 17
Program exited.
Run Code Online (Sandbox Code Playgroud)
有人可以告诉我为什么“sum”函数的第二次调用是在第一次调用之前通过通道进行的吗?在我看来,输出应该是:
17 -5
Run Code Online (Sandbox Code Playgroud)
我还使用非缓冲通道对此进行了测试,它也给出了相同的输出顺序。我缺少什么?
您在代码中调用 go 例程,并且无法判断例程何时结束以及值何时将传递到缓冲通道。
由于此代码是异步的,因此每当例程完成时,它都会将数据写入通道并在另一端读取。在上面的示例中,您仅调用两个 go 例程,因此行为是确定的,并且在大多数情况下都会以某种方式生成相同的输出,但是当您增加 go 例程时,输出将不相同,并且顺序将不同,除非您使它是同步的。
例子:
package main
import "fmt"
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
c <- sum // send sum to c
}
func main() {
a := []int{7, 2, 8, -9, 4, 2, 4, 2, 8, 2, 7, 2, 99, -32, 2, 12, 32, 44, 11, 63}
c := make(chan int)
for i := 0; i < len(a); i = i + 5 {
go sum(a[i:i+5], c)
}
output := make([]int, 5)
for i := 0; i < 4; i++ {
output[i] = <-c
}
close(c)
fmt.Println(output)
}
Run Code Online (Sandbox Code Playgroud)
此代码在不同示例运行中的输出是
Run Code Online (Sandbox Code Playgroud)[12 18 0 78 162] [162 78 12 0 18] [12 18 78 162 0]
这是因为 goroutine 将输出异步写入缓冲通道。
希望这可以帮助。