Golang 通道,执行顺序



我正在学习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.

有人可以告诉我为什么"sum"函数的第二次调用在第一次调用之前通过通道? 在我看来,输出应该是:

17 -5

我还使用无缓冲通道对此进行了测试,它也给出了相同的输出顺序。 我错过了什么?

您在代码中调用 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)
}

此代码在不同示例运行中的输出为

[12 18 0 78 162] 
[162 78 12 0 18]
[12 18 78 162 0]

这是因为 goroutines 将输出异步写入缓冲通道。

希望这有帮助。

运行 golang.org 沙盒时,我每次都得到相同的结果。如上所述。但是当我在自己的沙箱(在我的计算机上(运行相同的代码片段时,它有时会更改线程的顺序。这要令人满意得多。它表明我不能期望线程执行任何特定的顺序,这很直观。 我只是想不通为什么我得到相同的执行顺序,这与线程的启动顺序相反。 我认为这只是golang.org沙盒上的运气。

Goroutines是异步启动的,它们可以按任何顺序写入通道。如果您稍微修改一下示例,则更容易看到:

package main
import (
"fmt"
"time"
)
func sum(a []int, c chan int, name string, sleep int) {
fmt.Printf("started goroutine: %sn", name)
time.Sleep(time.Second * time.Duration(sleep))
sum := 0
for _, v := range a { 
sum += v
}   
fmt.Printf("about end goroutine: %sn", name)
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, "A", 1)
go sum(a[3:6], c, "B", 1)
x := <-c 
y := <-c 
// x, y := <-c, <-c // receive from c
fmt.Println(x, y)
}

https://play.golang.org/p/dK4DT0iUfzY

结果:

started goroutine: B
started goroutine: A
about end goroutine: A
about end goroutine: B
17 -5

最新更新