Golang通道，执行顺序

Question

Golang通道，执行顺序

5

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

我也用了一个非缓冲通道进行测试，输出的顺序也是相同的。我错过了什么吗？

- mikekehrli

1

可能是Golang通道输出顺序的重复问题。 - Himanshu

3个回答

2

在运行golang.org沙盒时，我每次都得到相同的结果。正如上面所述。但是当我在自己的沙盒（在我的电脑上）上运行相同的代码段时，有时会更改线程的顺序。这更令人满意。它表明我不能期望任何特定的线程执行顺序，这是直观的。我只是无法弄清楚为什么我得到了相同的执行顺序，而且它与线程启动的顺序相反。我认为这只是golang.org沙盒的随机结果。

- mikekehrli

3

在沙盒中每次得到相同结果的原因是你的程序的结果被缓存了。 - Akavall

啊，这很有道理。我现在对这个问题非常清楚了。我看到了一些看起来是确定性的东西，但实际上并不是。我也在自己的电脑上运行了这个程序。只要我以某种方式弄脏了文件，即使是我第一篇帖子中的原始片段，结果也是随机的。 - mikekehrli

1

Go协程是异步启动的，它们可以以任何顺序写入通道。如果您稍微修改一下示例，就会更容易看出来：

package main

import (
    "fmt"
    "time"
)

func sum(a []int, c chan int, name string, sleep int) {
    fmt.Printf("started goroutine: %s\n", name)
    time.Sleep(time.Second * time.Duration(sleep))

    sum := 0

    for _, v := range a { 
        sum += v
    }   
    fmt.Printf("about end goroutine: %s\n", 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

- Akavall

谢谢。这很有帮助。你的答案完全正确。我选择了Hamza的答案，可能是因为我先看到了他的答案，直到我也读了你的答案后才恍然大悟。但我也给了你点赞。实际上，我问错了问题。真正的问题是为什么第二个线程总是在第一个线程之前完成。至少在第二个线程之前，第一个线程应该完成超过一半的时间。我不明白为什么Hamza的代码片段是随机的，而我的不是。但是，很明显，在涉及未缓冲通道时，我不能期望任何特定的顺序。 - mikekehrli

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Hamza Anis · Accepted Answer

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

The output for this code on different sample runs was
[12 18 0 78 162] 

[162 78 12 0 18]

[12 18 78 162 0]

这是因为goroutine异步将输出写入缓冲通道。希望这能帮到你。