缓冲通道容量4，接受5个元素而不阻塞

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《缓冲通道容量4，接受5个元素而不阻塞》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我有 go 代码，它基本上同时运行两个 go 例程。其中一个将（1-10）中的 10 个 int 数字发送到缓冲通道“ch”（容量为 4），另一个 go 例程借助 for range loop 从通道读取值

package main

  import (
      "fmt"
      "sync"
      "time"
      "runtime"
  )

  func dosm(ch chan int, wg *sync.waitgroup) {
      defer wg.done()

      for i := 1; i <= 10; i++ {
          fmt.println("sending", i)
          ch <- i
          fmt.println("sent", i)
      }

      close(ch)
  }

  func dosm2(ch chan int, wg *sync.waitgroup) {
      defer wg.done()

      time.sleep(5 * time.second)
      for v := range ch {
          fmt.println("result:", v)
      }
  }

  func main() {
      runtime.gomaxprocs(1)
      var wg sync.waitgroup
      ch := make(chan int, 4)

      wg.add(2)
      go dosm(ch, &wg)
      go dosm2(ch, &wg)
      wg.wait()
  }

可以在下面的输出中找到问题。

dosm() 通过通道发送 4 个 int，并且 go 调度程序会阻塞 go 例程，直到 dosm2() 从通道读取这 4 个值。之后，缓冲区为空，dosm() 发送 1 个 int，dosm2() 立即读取它。现在，缓冲区再次变空并准备发送 4 个值。然而，尽管 dosm() 的容量很大，但它还是会以某种方式发送 5 个值（6、7、8、9、10）。

sending 1
sent 1
sending 2
sent 2
sending 3
sent 3
sending 4
sent 4
sending 5
result: 1
result: 2
result: 3
result: 4
result: 5
sent 5
sending 6
sent 6
sending 7
sent 7
sending 8
sent 8
sending 9
sent 9
sending 10
sent 10
result: 6
result: 7
result: 8
result: 9
result: 10

知道为什么会这样吗？或者我错过了什么？

解决方案

示例解释。

result: 5
sent 5
sending 6
sent 6
sending 7
sent 7
sending 8
sent 8
sending 9
sent 9
sending 10
sent 10
result: 6

打印了 result 5，然后我们看到 sent 6-7-8-9-10，然后我们看到打印了 result 6。这并不意味着值 6-7-8-9-10 都在通道的缓冲区中（显然它们不是）。已从通道接收到值 6，但后续 fmt.println() 行尚未执行。但由于收到了 6，缓冲区中只有 3 个数字，因此可以在通道上发送 10，如输出中所示。

以下是可能导致此输出的执行：

• 发送 goroutine 发送 4 个值，并打印
• 发送 goroutine 块
• 接收goroutine接收一个值
• 发送 goroutine 发送另一个值并打印
• 接收 goroutine 打印
• 接收goroutine接收剩余的值

通过这种交错，发送 goroutine 看起来就像发送了 5 个值。

简而言之：当涉及多个 goroutine 时，打印到 stdout 可能不会显示 goroutine 的实际交错。

今天关于《缓冲通道容量4，接受5个元素而不阻塞》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！