Golang channel 用法与实现原理_golang channel 实现原理

1.简介

Golang channel 是一种并发原语，用于在不同 Goroutine 之间进行通信和同步。

本质上，channel 是一种类型安全的 FIFO 队列，它可以实现多个 Goroutine 之间的同步和通信。

channel 是一种引用类型，即使是在不同的 Goroutine 之间传递 channel 时，它们仍然指向相同的底层数据结构。

2.用法

channel 按照接收和发送数据分为三种。

chan T      	// 可以被用来发送和接收类型 T 的值
chan<- T  		// 只能被用来发送类型 T 的值
<-chan T      	// 只能被用来接收类型 T 的值
1
2
3

其中，T 表示 channel 中元素的类型。

其中 <- 操作符指定信道的方向，发送或接收。若没有给定方向，那么该信道是双向的。信道可通过类型转换或赋值被强制为只发送或只接收。

在 Golang 中，可以使用 make 函数初始化 channel。

ch := make(chan T) 		// 无缓冲信道
ch := make(chan T, 0)	// 无缓冲信道
ch := make(chan T, 100)	// 带缓冲信道
1
2
3

其结果值充当了对底层数据结构的引用。初始化时可以为信道设置缓冲区大小，默认值是零，表示不带缓冲的或同步的信道。

未初始化的信道值为 nil。

var ch chan T  // ch 为 nil
1

channel 可以使用以下操作来实现同步和通信：

• 发送操作: 用于将数据发送到channel中，语法为 ch <- data。
• 接收操作: 用于从channel中接收数据，语法为 data := <- ch。
• 关闭操作: 用于关闭 channel，语法为 close(ch)。

需要注意的是，发送和接收操作都是阻塞的，即如果没有 goroutine 同时进行对应的操作，它们将一直阻塞，直到其他 goroutine 进行操作为止。而关闭操作是非阻塞的。即使 channel 已经被关闭，仍然可以从中读取数据。

3.三种状态

channel 有三种状态：未关闭，已关闭和 nil。

对三种不同的 channel 进行操作，会有不同的结果。

4.实现原理

数据结构

channel 是一个结构体，运行时使用 runtime.hchan（go 1.19 runtime/chan.go）结构体表示。

type hchan struct {
	qcount   uint           // total data in the queue
	dataqsiz uint           // size of the circular queue
	buf      unsafe.Pointer // points to an array of dataqsiz elements
	elemsize uint16
	closed   uint32
	elemtype *_type // element type
	sendx    uint   // send index
	recvx    uint   // receive index
	recvq    waitq  // list of recv waiters
	sendq    waitq  // list of send waiters

	// lock protects all fields in hchan, as well as several
	// fields in sudogs blocked on this channel.
	//
	// Do not change another G's status while holding this lock
	// (in particular, do not ready a G), as this can deadlock
	// with stack shrinking.
	lock mutex
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

字段的具体含义如下：

qcount：表示当前队列中元素的个数。
dataqsiz：表示队列中元素的个数上限，即缓冲区大小。
buf：指向缓存的环形数组，存储实际元素的值。由于 channel 内的元素在堆上分配，因此 buf 是一个 unsafe.Pointer 类型的指针。
elemsize：表示单个元素的大小，以字节为单位。
closed：表示 channel 是否已关闭，0 表示未关闭，1 表示已关闭。
recvx：表示下一个被接收的元素在 buf 中的位置。
sendx：表示下一个被发送的元素在 buf 中的位置。
recvq：接收者的等待队列，用于存储等待从 channel 中读取数据的 goroutine。
sendq：发送者的等待队列，用于存储等待向 channel 中发送数据的 goroutine。
lock：保护 channel 的锁，防止多个 goroutine 同时访问 channel 时发生竞争条件。这里的 lock 是一个 mutex 类型的变量。

需要注意的是，这里的 waitq 和 mutex 分别表示等待队列和互斥锁，是 Golang 内部实现 channel 同步和通信机制所需要的结构体，由 Golang 运行时库提供支持。

原理概述

在 Golang 中，channel 是用于协程之间通信的重要机制，其内部实现涉及到以下几个方面：

数据结构：
channel 本质上是一个带有同步功能的队列，Go 语言中的 channel 通过数据结构来实现同步和通信。具体而言，channel 内部包含了一个指向队列数据的指针和两个指向队列头和尾的索引。

内存管理：
channel 内部存储的元素是在堆上分配的，这意味着在使用 channel 时不用考虑内存分配和回收的问题，由 Go 运行时自动管理。

同步机制：
channel 的本质是一种同步机制，因此其内部实现必须包括同步相关的机制，以确保通信的正确性。Go 语言采用了类似于信号量的方法实现 channel 的同步，即在发送和接收操作时使用锁和条件变量来实现同步。

调度器：
Golang 中的调度器负责协程的调度和管理，其在 channel 的实现中起到了重要的作用。调度器通过在不同协程之间切换来实现 channel 的通信和同步。

具体来说，当一个协程试图向 channel 发送数据时，调度器会检查 channel 的缓冲区状态。如果 channel 的缓冲区未满，则将数据写入缓冲区并唤醒等待接收的协程。如果 channel 的缓冲区已满，则当前协程会被阻塞，等待其他协程取走缓冲区中的数据。

当一个协程试图从 channel 中接收数据时，调度器会检查 channel 的缓冲区状态。如果 channel 的缓冲区非空，则将缓冲区中的数据读出并唤醒等待发送的协程。如果 channel 的缓冲区为空，则当前协程会被阻塞，等待其他协程向缓冲区中写入数据。

在 channel 的实现中，Go 语言使用了类似于操作系统中的管道机制，以及用于进程间通信的信号量机制，通过同步、调度等多种机制实现了协程之间的通信和同步。

5.小结

总的来说，channel 是 Golang 中非常重要的并发原语，它为多个 goroutine 之间的通信和同步提供了方便而高效的方式。使用 channel 需要注意它的阻塞特性以及引用类型的特点。channel 的底层实现基于管道，使用两个 goroutine 之间的无缓冲管道来进行通信，确保操作的顺序满足 FIFO 规则。

---

参考文献

OpenAI ChatGPT
Go 语言Channel 实现原理精要 - 面向信仰编程
深入Go 并发原语— Channel 底层实现 - 冰霜之地