Go channel结构体源码和读写和关闭过程详解
更新时间：2023年05月04日 16:02:56 作者：CCSU__LRF
这篇文章主要介绍了Go channel结构体源码和读写和关闭过程,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
- 简而言之，channel维护了一个带指针的接受和发送的队列,其中包含mutex锁保证并发安全，数据类型，元素个数，元素大小，channel状态
- 然后读写操作，先看队列是否可以取出，然后看缓冲区，最后放入接受/发送队列
- 关闭就是唤醒所有goroutine然后将他们的标志位设为1，表示关闭，以后有人访问就是nil
结构体源码
type hchan struct {
qcount uint // 当前队列中元素的数量
dataqsiz uint // 缓冲区大小，即可以缓存的元素数量
buf unsafe.Pointer // 指向队列的缓冲区
elemsize uint16 // 每个元素的大小
closed uint32 // channel 是否已关闭的标志
elemtype *_type // channel 中元素的类型
sendx uint // 下一次发送元素的位置
recvx uint // 下一次接收元素的位置
recvq waitq // 等待接收的 goroutine 队列
sendq waitq // 等待发送的 goroutine 队列
lock mutex // 用于保护 channel 的互斥锁
}发送数据
当一个 goroutine 要向 channel 中发送数据时，它会执行 chansend 函数。
- 这个函数首先会对 channel 进行加锁，然后判断是否有等待接收的 goroutine
- 如果有，则直接将数据发送给它；否则，如果缓冲区未满，则将数据放入缓冲区，队列中元素数量加一；
- 如果队列已满，则将当前 goroutine 加入等待发送的 goroutine 队列中，并阻塞它，等待其他 goroutine 接收数据。
接受数据
当一个 goroutine 要从 channel 中接收数据时，它会执行 src/runtime/chan.go 中的 chanrecv 函数。
- 这个函数也会对 channel 进行加锁，然后判断是否有等待发送的 goroutine，如果有，则直接从它那里接收数据；
- 否则，如果缓冲区元素的数量大于 0，则从缓冲区中取出一个元素，并将队列中元素数量减一。
- 如果缓冲区为空，则将当前 goroutine 加入等待接收的 goroutine 队列中，并阻塞它，等待其他 goroutine 发送数据。
关闭channel
当一个 goroutine 要关闭 channel 时，它会执行 src/runtime/chan.go 中的 closechan 函数。
- 这个函数会对 channel 进行加锁，然后将
closed标志置为 1，表示 channel 已经关闭。 - 然后遍历等待发送和等待接收的 goroutine 队列，将它们全部唤醒，并返回一个特殊的值来表示 channel 已经关闭。
到此这篇关于Go channel结构体源码和读写和关闭过程的文章就介绍到这了,更多相关go channel结构体源码内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文介绍了如何使用Go语言和WebSocket技术构建一个简单的多人聊天室系统,包括客户端连接管理、消息广播和并发处理,最后,通过编写main.go、hub.go和client.go等核心代码模块,具有一定的参考价值,感兴趣的可以了解一下2024-10-10
Golang是一种强类型语言，所以Golang的类型转换和C/C++ java等语言的类型转换还有点区别，本文讲通过一些简单的示例带大家深入了解一下Golang中的类型转换，需要的可以参考下2023-05-05
这篇文章主要介绍了解决golang内存溢出的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-08-08
这篇文章主要为大家介绍了k8s容器互联flannel vxlan通信原理详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-04-04
Go基于GORM 获取当前请求所执行的 SQL 信息(思路详解)
这篇文章主要介绍了Go基于GORM 获取当前请求所执行的 SQL 信息(思路详解),本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-01-01
Go语言追求简洁优雅，所以，Go语言不支持传统的 try…catch…finally 这种异常，因为Go语言的设计者们认为，将异常与控制结构混在一起会很容易使得代码变得混乱，今天给大家介绍golang panic及处理机制，需要的朋友参考下吧2021-08-08
Golang实现Directional Channel(定向通道)
这篇文章主要介绍了Golang实现Directional Channel(定向通道)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-02-02
本文主要介绍了Go简单实现协程池的实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-06-06
Gin是一个用Go语言编写的web框架,它是一个类似于martini但拥有更好性能的API框架, 由于使用了httprouter,速度提高了近40倍,本文给大家介绍了Go语言web框架Gin响应客户端有哪些方式,文中有详细的代码示例供大家参考,需要的朋友可以参考下2024-10-10
Go1.21新增内置函数(built-in functions)详解
Go 1.21新增的内置函数分别是 min、max 和 clear,这篇文章主要带大家一起了解一下这几个函数的用途和使用示例,感兴趣的小伙伴可以学习一下2023-08-08
最新评论