ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

Go 语言入门 1-管道的特性及实现原理

2022-09-01 15:03:23  阅读:165  来源: 互联网

标签:协程 入门 队列 读写 元素 chan 管道 Go


入坑 go 也快一年了,从今天开始会定期分享一下 Go 语言学习过程中的一些基础知识。

 

go 语言中的管道, 主要是用于协程之间的通信, 比 UNIX 的管道更加轻量和易用。

 

我们先看一下管道的数据结构:

 

type hchan struct {  gcount   uint  // 环形队列剩余元素个数  dataqsiz uint // 环形队列长度  buf      unsafe.Pointer // 环形队列指针  elemsize uint16  // 每个元素大小  closed   uint32  // 标识关闭状态  elemtype *_type  // 元素类型  sendx    uint   // 下一个元素写入时的下标  recvx    uint   // 下一个元素读取时的下标  recvq    waitq  //  等待读消息的队列  sendq    waitq  // 等待写消息的队列  lock     mutex  // 互斥锁, 保障管道无法并发读写}

源码链接:

https://github.com/golang/go/blob/0d0193409492b96881be6407ad50123e3557fdfb/src/runtime/chan.go#L33


通过上述数据结构, 我们可以理解管道是由三部分组成的:

环形队列

读写等待队列

队列元素基本信息

 

从管道读取数据时, 如果管道缓冲区为空或者没有缓冲区, 那么当前协程就会阻塞, 然后放入 recvq 队列中。

 

往管道写入数据时, 如果管道缓冲区为空或者缓冲区满了, 那么当前协程就会阻塞, 然后放入 sendq 队列中。

 

读阻塞的协程会被新来的写数据的协程唤醒。

写阻塞的协程会被新来的读数据的协程唤醒。

 

同时上述数据结构中, 我们可以看到一个管道中只能传递一种元素类型。 如果想数据类型动态化, 可以传递 interface。

 

管道的操作:

 

初始化有两种方式:

 

变量声明:

var ch chan int  // 声明一个新的管道

使用 make:

ch1 := make(chan string)  // 无缓冲管道ch1 := make(chan string 3)  // 有缓冲管道

 

管道的读写是通过操作符: 「<-」控制的,管道在左边表示把右侧数据写入到管道中, 管道在右边表示读取管道数据赋值给左侧变量。

 

ch1 := make(chan string)  // 初始化ch1 <- "gjl";  // 把 gjl 字符串写入到管道中c := <- ch1;  // 读取管道数据并交给 c 变量fmt.Println(c) // 输出

 

 

同时也可以通过操作符来限制管道的读写权限。

 

举个栗子

标签:协程,入门,队列,读写,元素,chan,管道,Go
来源: https://www.cnblogs.com/guanjinglin/p/16646496.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有