详解Golang中channel的实现

 更新时间:2023年09月13日 09:44:24   作者:mjiarong  
channel俗称管道,用于数据传递或数据共享,其本质是一个先进先出的队列,使用goroutine+channel进行数据通讯简单高效,同时也线程安全,本文就给大家讲讲Golang中channel的实现,需要的朋友可以参考下

1、channel的基本概念

channel俗称管道,用于数据传递或数据共享,其本质是一个先进先出的队列,使用goroutine+channel进行数据通讯简单高效,同时也线程安全,多个goroutine可同时修改一个channel,不需要加锁。

channel可分为三种类型:

  • 只读channel:只能读channel里面数据,不可写入
  • 只写channel:只能写数据,不可读
  • 一般channel:可读可写

2、channel的数据结构

type hchan struct {
    qcount uint // 队列中元素个数 
    dataqsiz uint // 循环队列的大小 
    buf unsafe.Pointer // 指向循环队列 
    elemsize uint16 // 通道里面的元素大小 
    closed uint32 // 通道关闭的标志 
    elemtype *_type // 通道元素的类型 
    sendx uint // 待发送的索引,即循环队列中的队尾指针front 
    recvx uint // 待读取的索引,即循环队列中的队头指针rear 
    recvq waitq // 接收等待队列 
    sendq waitq // 发送等待队列 
    lock mutex // 互斥锁 
}

3、channel的hchan结构图

hchan结构体中的buf指向一个数组,用来实现循环队列,sendx是循环队列的队尾指针,recvx是循环队列的队头指针。dataqsize是缓存型通道的大小,qcount是记录通道内元素个数。

循环队列一般使用空余单元法来解决队空和队满时候都存在font=rear带来的二义性问题,但这样会浪费一个单元。golang的channel中是通过增加qcount字段记录队列长度来解决二义性,一方面不会浪费一个存储单元,另一方面当使用len函数查看队列长度时候,可以直接返回qcount字段,一举两得。 

hchan结构体中另一重要部分是recvq,sendq,分别存储了等待从通道中接收数据的goroutine,和等待发送数据到通道的goroutine。两者都是waitq类型。sudog是对goroutine的一种封装

type waitq struct {
    first *sudog
    last *sudog
}

waitq是一个结构体类型,waitq和sudog构成双向链表,其中sudog是链表元素的类型,waitq中first和last字段分别指向链表头部的sudog,链表尾部的sudog。

channel 的发送和接收操作本质上都是 “值的拷贝”,无论是从 sender goroutine 的栈到 chan buf,还是从 chan buf 到 receiver goroutine,或者是直接从 sender goroutine 到 receiver goroutine。

channel读取写入流程

操作nil channelclosed channelnot nil,not closed

close

panic

panic

正常关闭

读<-ch

阻塞

如果channel关闭前有数据,则会正常读取到数据.如果没有数据则会读取到对应元素类型的空值

阻塞或正常读取数据,缓冲型channel为空或非缓冲型channel等待发送者时会阻塞

写ch<-

阻塞

panic

阻塞或正常写入数据,非缓冲型channel等待接收者或缓冲型channel buf满时会被阻塞

到此这篇关于详解Golang中channel的实现的文章就介绍到这了,更多相关Golang channel实现内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go中使用gjson来操作JSON数据的实现

    Go中使用gjson来操作JSON数据的实现

    本文主要介绍了Go中使用gjson来操作JSON数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • golang基础之字符串与int、int64类型互相转换

    golang基础之字符串与int、int64类型互相转换

    这篇文章主要给大家介绍了关于golang基础之字符串与int、int64类型互相转换的相关资料,在Go语言中string转int是一项常见的操作,需要的朋友可以参考下
    2023-07-07
  • Go中变量命名规则与实例

    Go中变量命名规则与实例

    命名规则涉及变量、常量、全局函数、结构、接口、方法等的命名,下面这篇文章主要给大家介绍了关于Go中变量命名的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-01-01
  • 详解Go语言中for循环,break和continue的使用

    详解Go语言中for循环,break和continue的使用

    这篇文章主要通过一些示例为大家介绍一下Go语言中for循环、break和continue的基本语法以及使用,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一下
    2022-06-06
  • go slice不同初始化方式性能及数组比较详解

    go slice不同初始化方式性能及数组比较详解

    这篇文章主要为大家介绍了go slice不同初始化方式性能及数组比较示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • go protobuf 详解

    go protobuf 详解

    Protobuf是Protocol Buffers的简称,它是Google公司开发的一种数据描述语言,是一种轻便高效的结构化数据存储格式,可以用于结构化数据串行化,或者说序列化,这篇文章主要介绍了protobuf 详解,需要的朋友可以参考下
    2024-01-01
  • Golang template 包基本原理分析

    Golang template 包基本原理分析

    这篇文章主要为大家介绍了Golang template 包基本原理分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-09-09
  • Go语言每天必学之switch语句

    Go语言每天必学之switch语句

    这篇文章主要为大家详细介绍了Go语言每天必学之switch语句的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-12-12
  • goland配置自动注释的实现

    goland配置自动注释的实现

    本文主要介绍了goland配置自动注释的实现,文中通过图文示例介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-08-08
  • golang os.Eixt使用示例

    golang os.Eixt使用示例

    在Go语言中,os.Exit函数用于立即终止程序并返回一个指定的退出状态码,本文就来介绍一下golang os.Eixt使用,具有一定的参考价值,感兴趣的可以了解一下
    2024-10-10

最新评论