go - Go 中缓冲 channel 和非缓冲 channel 之间的测距有什么区别？

Question

我正在尝试类似于以下模式的操作:

func sendFunc(n int, c chan int) {
    for i := 0; i < n; i++ {
        c <- i
        fmt.Println("Pushed")
    }
    close(c)
}

func main() {
    c := make(chan int, 10)
    go sendFunc(10, c)
    // Receive from the channel
    for i := range c {
        fmt.Println(i)
    }
}

输出看起来是同步的，像这样:

Pushed
Pushed
Pushed
Pushed
Pushed
Pushed
Pushed
Pushed
Pushed
Pushed
0
1
2
3
4
5
6
7
8
9

如果我将缓冲 channel 更改为非缓冲 channel :

c := make(chan int)

结果似乎是异步的:

Pushed
0
1
Pushed
Pushed
2
3
Pushed
Pushed
4
5
Pushed
Pushed
6
7
Pushed
Pushed
8
9
Pushed

为什么它的行为不同？

已更新

所以我的场景是:在接收者中，每次从生产者接收到新数据时都会发出请求，结果显示调度程序直到所有数据都发送到 channel 后才会开始接收(给定一个缓冲具有足够空间的 channel )，除非生产者暂停(例如通过调用 time.sleep())。因此，我最终使用了非缓冲 channel ，这样等待响应的时间和生产者处理数据的时间可以重叠，从而实现更好的并发性。

Answer 1

正如 Cerise Limón 所说:这是运行时计划如何成为例程的结果。基本上，只要不阻塞或返回，go routine 就会运行。所以打电话go sendFunc(10, c)将执行直到它阻塞或返回。如果你把 <-time.After(1)在sendFunc , 该函数将突然阻塞，您将产生调度程序将调度另一个例程的效果。

这是 Playground 上的一个小例子: https://play.golang.org/p/99vJniOf3_

哪个更好这个问题很难回答。免责声明:到目前为止，我不是这方面的专家，但我想这是一种权衡。虽然较小的缓冲区会减少单个消息在缓冲区中停留的时间，但它会触发重新安排 go routines，这通常会花费一些时间。

另一方面，较大的缓冲区会增加通过缓冲区的消息延迟，但另一方面会提高吞吐量。您还可以预先生成大量消息，如果您有一些对于一条或多条消息相同的静态开销(例如，请求单行输入与请求多行输入)，这会很有用。

有这个调度器的解释https://rakyll.org/scheduler/ .