考虑来自 http://www.golang-book.com/10/index.htm#section2 的乒乓球示例。

package main

import (
    "fmt"
    "time"
)

func pinger(c chan string) {
    for i := 0; ; i++ {
        c <- "ping"
    }
}

func ponger(c chan string) {
    for i := 0; ; i++ {
        c <- "pong"
    }
}

func printer(c chan string) {
    for {
        msg := <- c
        fmt.Println(msg)
        time.Sleep(time.Second * 1)
    }
}

func main() {
    var c chan string = make(chan string)

    go pinger(c)
    go ponger(c)
    go printer(c)

    var input string
    fmt.Scanln(&input)
}

作者写道:



然而,要实现这一点,Go 必须决定发送者可以发送到 channel 的顺序?否则,将无法保证 ping 会在 pong 之前发送(即您不能获得两个 ping 或连续两个 pong)。这是如何运作的?

最佳答案

pingpong goroutines 之间没有同步,因此不能保证响应会按顺序打印。

如果你强制 goroutines 以 GOMAXPROCS>1 进行比赛,你会得到随机输出:

pong
ping
ping
pong
ping
pong
ping
pong
pong

这甚至不是“乒乓”的例子,因为没有调用和响应。

关于concurrency - Go channel 中发送者的排序,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/29087538/

10-10 15:16