Go channel结构体源码和读写和关闭过程详解
作者:CCSU__LRF 发布时间:2024-04-26 17:31:08
简而言之,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 已经关闭。
来源:https://blog.csdn.net/csxylrf/article/details/130419871
猜你喜欢
- 前言哈喽,大家好,我是asong;前几天逛github发现了一个有趣的并发库-conc,其目标是:更难出现goroutine泄漏处理pani
- 抓取网页数据的思路有好多种,一般有:直接代码请求http、模拟浏览器请求数据(通常需要登录验证)、控制浏览器实现数据抓取等。这篇不考虑复杂情
- Python字典是另一种可变容器模型,且可存储任意类型对象,如字符串、数字、元组等其他容器模型。一、创建字典字典由键和对应值成对组成。字典也
- Python编程中经常遇到一些莫名其妙的错误, 其实这不是语言本身的问题, 而是我们忽略了语言本身的一些特性导致的,今天就来看下使用Pyth
- 我的坐标是深圳,2022年以来,大部分时候要求24小时,少部分时候要求48小时,更少的时候要求72小时,没有更长的情况。本文根据我的核酸检测
- 玩过knockoutjs的都知道,有一个强大的功能叫做component,而这个component有个牛逼的地方就是拥有自己的viewmod
- 一、本讲学习目标1.掌握构造方法的使用2.掌握析构方法的使用3.掌握self变量的使用二、构造方法(一)概述构造方法指的是__init__(
- 内部存储格式:世纪、年、月、日、小时、分钟、秒默认格式是:DD-MON-RR。SYSDATE 返回当前的系统时间。SELECT S
- 如果我们在标识列中插入值,例如: insert member(id,username) values(10,'a
- 今天试了一下用zipfile模块读取有密码的zip压缩文件。今天用winrar 5.6将一个名字为1.xlsx的excel文件打包成1.zi
- 第一种 使用pygame模块 pygame.mixer.init() pygame.mixer.music.load
- 引言对MySQL数据库的查询,除了基本的查询外,有时候需要对查询的结果集进行处理。例如只取10条数据、对查询结果进行排序或分组等等。一、常用
- 可直接用这行命令!: pip install -U scikit-learn其他命令: (1)更新pippython -m pip inst
- 我们经常会遇到一些对于多媒体文件修改的操作,像是对视频文件的操作:视频剪辑、字幕编辑、分离音频、视频音频混流等。又比如对音频文件的操作:音频
- Fibonacci斐波那契数列,很简单,就是一个递归嘛,学任何编程语言可能都会做一下这个。最近在玩Python,在粗略的看了一下Learni
- 尽管有很多规范URL的标准,例如RFC 3987,但实际应用中却非常混乱。本文主要介绍浏览器发送URL到服务器的一些特性,作为开发和应用的参
- 介绍:今天在使用django的时候忽然想用到,如何匹配多个关键字的操作,我们知道django有一个objects.filter()方法,我们
- 这是为了实现一个效果,而提前作的测试代码!看起来很简单的一个东西,到这会,大约四个小时过去了。不知道是IE6的BUG;还是我自已的BUG!有
- 记录mysql5.7.14安装与配置过程,梳理成文,希望对大家有所帮助。1.配置文档: ####################配
- vue-cli在开发前,我们要至少通读一遍vue官方文档和API(看官方文档是最重要的,胜过看五十、一百篇博客),英文阅读能力还行的建议阅读