chan 是 golang 中的数据结构，俗称管道，用于并发控制和阻塞，其实不也不太懂一步步来

创建

channel 只能使用 make 来创建

c := make(chan int) // 创建无缓冲区的chan

c2 := make(chan int,2) // 创建2个缓冲区的chan

这个无缓冲区的 channel 一旦接收了值就会在当前 goroutines 阻塞

所以一般配合 goroutines 在后台使用

无缓冲区的 channel

无缓冲区的 channel 在一个地方接收值只能等待接收方接收才能进行下一次读入

package main

import (
	"fmt"
	"time"
)

func main() {
	c := make(chan int)
	go func() {
		fmt.Println("[Goroutine] Send 1")
		c <- 1
		fmt.Println("[Goroutine] Send 2")
		c <- 2
	}()

	time.Sleep(time.Millisecond * 10) // 稍等，确保 goroutine 启动

	fmt.Println("[Main] Receive 1")
	v1 := <-c
	fmt.Println("[Main] Got:", v1)

	fmt.Println("[Main] Receive 2")
	v2 := <-c
	fmt.Println("[Main] Got:", v2)
}

执行结果：

[Goroutine] Send 1
[Main] Receive 1
[Main] Got: 1
[Main] Receive 2
[Goroutine] Send 2
[Main] Got: 2

正如上述代码所示，往 无缓冲的 channel 置入值，接收值这个过程会阻塞当前goroutine，直到在另外一个 goroutine 拿到为止

v3 := <-c
fmt.Println("[Main] Got:", v3)

如果写成这样那么就会持续阻塞，造成死锁问题

控制台的输出为

fatal error: all goroutines are asleep - deadlock!
]:
main.main()
        /code/demo/eventbus/1.go:27 +0x214

有缓冲区的 channel

与无缓冲区的 channel 不同的是，有缓冲区的 channel 内部是可以存储值的，如果在没有接收方时，依旧是可以往 channel 发送值，直到发送的值的个数等于缓冲区容量的时候，channel 就会被阻塞

package main

import (
	"fmt"
	"time"
)

func main() {
	c := make(chan int, 2)
	go func() {
		fmt.Println("[Goroutine] Send 1")
		c <- 1
		fmt.Println("[Goroutine] Send 2")
		c <- 2
	}()

	time.Sleep(time.Millisecond * 10) // 稍等，确保 goroutine 启动

	fmt.Println("[Main] Receive 1")
	v1 := <-c
	fmt.Println("[Main] Got:", v1)

	fmt.Println("[Main] Receive 2")
	v2 := <-c
	fmt.Println("[Main] Got:", v2)
}

执行结果：

[Goroutine] Send 1
[Goroutine] Send 2
[Main] Receive 1
[Main] Got: 1
[Main] Receive 2
[Main] Got: 2

可以发现，有缓冲区并不像无缓冲区那样，在置入一个值就会阻塞，当前goroutine 会被挂起，有缓冲区的 channel 可以往内部置入多个值，仅当发送个数等于其缓冲区容量的时候，才会被挂起

所以无缓冲区是同步的，在消费者消费完才能继续生产 有缓冲区是异步的，无需等待消费者消费完

无缓冲区有点像一个共用的杯子，只有牛奶满了，顾客才能购买并且喝完才能继续挤奶 有缓冲区就是一个车间，可以一直生产牛奶直到车间满为止，消费者是可以直接去车间喝牛奶的