通道缓冲区如何工作？ [复制]

Question

我通过一系列定义来弄清楚缓冲区是如何工作的，但我就是不明白。下面是一个示例，我更改了缓冲区的值，但我不知道它的作用。有人可以根据这个例子向我解释它并提供一些关于它如何/为什么工作的测试用例吗？谢谢。

package main

import (
    "fmt"
    "time"
)

func send(out, finish chan bool) {
    for i := 0; i < 5; i++ {
        out <- true
        time.Sleep(1 * time.Second)
        fmt.Println("Fin d'une écriture")
    }
    finish <- true
    close(out)
}
func recv(in, finish chan bool) {
    for _ = range in {
        fmt.Println("Fin d'une lecture")
        time.Sleep(10 * time.Second)
    }
    finish <- true
}
func main() {
    chanFoo := make(chan bool, 3)
    chanfinish := make(chan bool)
    go send(chanFoo, chanfinish)
    go recv(chanFoo, chanfinish)
    <-chanfinish
    <-chanfinish
}

Answer 1

如果通道没有缓冲区，则一次只能在其上发送一个项目。这意味着在其上发送的代码将阻塞，直到某个接收器从通道中读取该项目。这是一个人为的例子； https://play.golang.org/p/HM8jdIFqsN 主包

import (
    "fmt"
)


func main() {
   blocker := make(chan bool)
   nonBlocker := make(chan bool, 5)

   for i := 0; i < 5; i++ {
        nonBlocker <- true
        fmt.Println("We keep going")
   }

   go func () {

    for i := 0; i < 5; i++ {
        blocker <- true
        fmt.Println("We block cause that channel is full")
   } }()

}

我可以做很多其他的事情来演示相同的内容，但基本思想是，如果您将通道传递给某个 goroutine 并且通道没有缓冲，则在通道上发送的 goroutine 将阻塞，直到它发送的项目收到。使用缓冲通道，只要缓冲区容量不足，您就可以发送。基本上，如果您启动正在工作并返回结果的 goroutine，并且它们的移动速度比生成它们的代码快，您可能需要使用缓冲通道来打开瓶颈。

编辑：如果还不清楚发生了什么，请查看此； https://play.golang.org/p/9SXc4M1to4

package main

import (
    "fmt"
)


func main() {
   blocker := make(chan bool)
   nonBlocker := make(chan bool, 5)

   for i := 0; i < 5; i++ {
        nonBlocker <- true
        fmt.Println("We keep going")
   }

   go func () {

    for i := 0; i < 5; i++ {
        blocker <- true
        fmt.Println("Now we see this cause the reciever keeps opening the channel up again!")
   } }()

   for i := 0; i < 5; i++ {
      <-blocker
   }
}