Go 知识chan

news2024/11/16 1:40:39

Go 知识chan

  • 1. 基本知识
    • 1.1 定义
    • 1.2 操作
    • 1.3 操作限定
    • 1.4 chan 读写
  • 2. 原理
    • 2.1 数据结构
    • 2.2 环形队列
    • 2.3 等待队列
    • 2.4 类型消息
    • 2.5 读写数据
    • 2.6 关闭chan
  • 3. 使用
    • 3.1 操作符使用
    • 3.2 select
    • 3.3 for-range

https://a18792721831.github.io/

1. 基本知识

chan是go里面里面提供的语言层面的协程间的通信方式，用于并发通信。

1.1 定义

  • 变量声明: var ch chan int // 声明一个int型的chan
    这种方式声明的chan，值为nil。并且每一种chan只能有一种类型。
  • make声明: ch1 := make(chan int)// 无缓存的chan，ch2 := make(chan int, 4)// 有缓冲的chan

1.2 操作

操作符<-表示数据流向，当chan在<-左边，表示数据流向chan，也就是向chan写入数据；当chan在<-右边，表示数据流出chan，
也就是从chan读取数据。

func TestChanOne(t *testing.T) {
	var ch chan int
	ch = make(chan int) // 无缓冲chan
	go func() {         // 创建一个协程，不断从chan中读取数据
		<-ch
	}()
	ch <- 1 // 写入数据，因为没有缓冲，如果没有上面那句，这句会阻塞

	var ch1 chan int
	ch1 = make(chan int, 1) // 有缓冲chan
	ch1 <- 2                // 因为有缓存，所以这句不会阻塞，但是因为缓冲长度是1，所以在写入就会阻塞
	fmt.Printf("len=%d, cap=%d\n", len(ch1), cap(ch1))
	fmt.Println(<-ch1) // 读取数据，因为有缓冲，并且有数据，所以不会阻塞
}

执行结果：
在这里插入图片描述

1.3 操作限定

默认的chan为双向可读写，chan在函数间传递的时候，可以使用操作符限制chan的读写。

func ChanRW(ch chan int) {
	ch <- 1
	<-ch
}

func ChanR(ch <-chan int) {
	ch <- 1
	<-ch
}

func ChanW(ch chan<- int) {
	ch <- 1
	<-ch
}

在这里插入图片描述在这里插入图片描述

1.4 chan 读写

chan无缓冲时，从chan读取数据会阻塞，直到有协程向chan写入数据。向chan写入数据也会阻塞，直到有协程读取数据。
chan有缓冲时，从chan读取数据，如果缓冲区中没有数据，那么也会阻塞，直到有协程写入数据。向chan写入数据，如果缓冲区已经满了，也会阻塞，直到有协程从chan中读取数据。
对于nil的chan,不管是读还是写，都是永久阻塞。 – 这个一定注意。
使用内置函数close可以关闭chan，尝试向关闭的chan写入数据会触发panic，但是仍然可以读取。
chan读取最多可以给两个变量赋值:

  i := <- ch
  j, ok := <- ch

第一个变量表示读取的值，第二个变量表示是否成功读取了数据。第二个变量不表示chan是否关闭。
对于关闭的有缓冲的chan存在两种情况：1. 缓冲区中没有数据; 2. 缓冲区中有数据。
对于有缓冲的chan并且用内置函数close进行关闭，在继续读取，针对缓冲区中没有数据，读取的第一个值是该类型的零值，第二个值为false，表示没有成功读取数据。
如果缓冲区中存在数据，那么第一个值是缓冲区中的第一个数据，第二个值是true，表示正确读取到数据。

也就是说，只有缓冲区中没有数据了，第二个值才能代表chan已经关闭。
当chan没有缓冲区的时候，第二个值可以认为是chan的关闭状态。

2. 原理

2.1 数据结构

在源码包的src/runtime/chan.go中定义了chan的结构：

type hchan struct {
	qcount   uint           // 当前队列中剩余的元素个数
	dataqsiz uint           // 环形队列的长度，即可以存放的元素个数
	buf      unsafe.Pointer // 环形队列指针
	elemsize uint16         // 每个元素的大小
	closed   uint32         // 关闭状态
	elemtype *_type         // 元素类型
	sendx    uint           // 写入位置
	recvx    uint           // 读取位置
	recvq    waitq          // 阻塞读协程队列
	sendq    waitq          // 阻塞写协程队列
	lock     mutex          // 互斥锁
}

可以看出，一个chan基本上由数据缓冲，类型信息，和协程等待队列组成。

2.2 环形队列

环形队列主要是存储缓冲数据的，其实实现一个缓冲队列非常简单，只需要一个数组就能实现，每次数组指针到达最后一个元素，那么就重置为0即可。

	var data []int
	data = make([]int, 10)
	for i := 0; i < 100; i++ {
		data[i] = i
		if i == len(data)-1 {
			i = 0
		}
	}

上面的if就是实现了环形队列，所以名字叫做环形队列，实际上可能是线性的结构。
在chan中使用双指针实现读取和写入数据，读指针表示读取的元素位置，写指针表示写入的元素位置。
当读指针等于写指针的时候，表示数据读取完毕，整个队列为空。
当写指针等于读指针的时候，表示队列满，无法写入。

2.3 等待队列

因为同一个chan可以传给多个协程，就会出现多个协程等待读取的情况；对于写数据也是相同的，那么此时就会根据先后顺序，组成等待队列，等待的协程组成了读阻塞队列和写阻塞队列。
当对chan进行写操作，那么唤醒读队列的协程；当对chan进行读操作，那么唤醒写队列的协程。
对于chan进行写操作，如果读协程队列为空，那么写操作阻塞；对于chan进行读操作，如果写协程队列为空，那么读操作阻塞。

需要注意，上述情况还有一个附件条件：无缓冲chan，如果是有缓冲chan，那么对于写操作，缓冲区满，对于读操作，缓冲区空。

2.4 类型消息

在chan的定义中，保存了类型消息和类型长度，类型消息主要是传递过程中赋值，类型长度主要是计算缓冲区中元素的位置。

2.5 读写数据

对于chan读写数据，实际上就是数据进入缓冲区和读出缓冲区的操作。
在实现上则存在一定的技巧：
写入数据时，如果读协程等待队列不为空，那么直接将数据给读协程等待队列的第一个协程即可，不进行数据缓冲区的数据写入，然后在唤醒，最后读取的操作，避免了数据的额外处理。
同样的，读取数据时，需要甄别一下，因为chan本质上是队列，需要符合先入先出的规则，在写入数据时，因为chan为空，所以不管有没有缓冲区，都可以直接将数据交给等待的读取协程。
但是在读取数据的时候，如果存在缓冲区，那么就必须从缓冲区中读取，读取数据后，环形写入协程等待队列，将数据写入缓冲区的队尾。
只有无缓冲区的chan，才可以直接从写等待协程队列中唤醒协程，并将数据直接交给读取协程。

2.6 关闭chan

关闭chan的时候，会将读等待队列和写等待队列的全部协程都唤醒。
对于读等待的协程，赋值该类型的零值，并且将第二个值赋值为false。

需要注意，对于chan，不会同时既存在读等待队列协程，又存在写等待队列协程。(长时间同时，瞬时的同时可能存在)

对于写等待的协程，直接触发panic，向close的chan写入数据，直接panic。
除此之外，这些操作也会panic:

  • 关闭nil的chan
  • 关闭已经关闭的chan
  • 向已经关闭的chan写入数据

3. 使用

3.1 操作符使用

使用<-进行操作，同时也可以限制在当前函数范围内chan的操作方式，读还是写，还是读写。

3.2 select

对于chan的使用，不管是读取还是写入，非常导致阻塞，但是很多时候，我们又不希望整个程序阻塞，因为是并发的，可能当前chan没有数据，但是别的chan可能有数据，那么就可以在等待一个chan的时候，处理其他chan的数据，增加程序的性能。
使用select就可以实现监控多个chan。

	sayOne := make(chan string)
	sayTwo := make(chan string)
	// 每两秒发送 one
	go func() {
		for {
			sayOne <- "one"
			time.Sleep(2 * time.Second)
		}
	}()
	// 每两秒发送 two
	go func() {
		for {
			sayTwo <- "tow"
			time.Sleep(2 * time.Second)
		}
	}()
	for {
		// 如果 select 中的任何 case 都没有触发，那么 select 本身是会阻塞的，直到某个 case 触发
		select {
		case msg := <-sayOne:
			fmt.Println(msg)
		case msg := <-sayTwo:
			fmt.Println(msg)
		// 但是因为 select 触发的 case 是随机的，所以这里可能并不会正确执行第三个case 	
		case <-time.After(10 * time.Second):
			return
		}
	}

在这里插入图片描述

要想按照程序10秒后退出，可以使用定时器进行超时退出：

	// 设置超时
	time.AfterFunc(10*time.Second, func() {
		os.Exit(0)
	})

在这里插入图片描述

除此之外，还可以使用default进行计时，然后进行超时退出操作。

	sayOne := make(chan string)
	sayTwo := make(chan string)
	// 每两秒发送 one
	go func() {
		for {
			sayOne <- "one"
			time.Sleep(2 * time.Second)
		}
	}()
	// 每两秒发送 two
	go func() {
		for {
			sayTwo <- "tow"
			time.Sleep(2 * time.Second)
		}
	}()
	// 设置超时
	//time.AfterFunc(10*time.Second, func() {
	//	os.Exit(0)
	//})
	tm := 0
	for {
		// 如果 select 中的任何 case 都没有触发，那么 select 本身是会阻塞的，直到某个 case 触发
		select {
		case msg := <-sayOne:
			fmt.Println(msg)
		case msg := <-sayTwo:
			fmt.Println(msg)
			// 但是因为 select 触发的 case 是随机的，所以这里可能并不会正确执行第三个case
		//case <-time.After(10 * time.Second):
		//	return
		default:
			if tm == 10 {
				return
			}
			time.Sleep(time.Second)
			tm++
		}
	}

在这里插入图片描述

3.3 for-range

使用<-操作符可以读取数据，除了使用<-操作符，还可以使用for-range进行数据的读取，就像读取一个数组一样。

	ch := make(chan int, 10)
	for i := 0; i < 10; i++ {
		ch <- i
	}
	for i := range ch {
		fmt.Println(i)
	}

在这里插入图片描述

使用for-range还有个好处，就是读取的数据都是成功的，不用去考虑数据是否读取成功，同时也不用考虑当chan关闭，当chan关闭后，for-range也能正确的处理。

	ch := make(chan int, 10)
	for i := 0; i < 10; i++ {
		ch <- i
	}
	// 5秒后关闭chan
	time.AfterFunc(5*time.Second, func() {
		close(ch)
	})
	// 每一秒读取一个元素
	for i := range ch {
		fmt.Println(i)
		time.Sleep(time.Second)
	}

在这里插入图片描述

即使第5秒的时候，chan被关闭了，也可以正确的读取全部的数据。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1414450.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

应用机器学习的建议

应用机器学习的建议

一、决定下一步做什么 在你得到你的学习参数以后&#xff0c;如果你要将你的假设函数放到一组新的房屋样本上进行测试&#xff0c;假如说你在预测房价时产生了巨大的误差&#xff0c;你想改进这个算法&#xff0c;接下来应该怎么办&#xff1f;实际上你可以考虑先采用下面的几种…
阅读更多...
「QT」QString类的详细说明

「QT」QString类的详细说明

✨博客主页何曾参静谧的博客📌文章专栏「QT」QT5程序设计📚全部专栏「VS」Visual Studio「C/C++」C/C++程序设计「UG/NX」BlockUI集合「Win」Windows程序设计「
阅读更多...
并查集:连通块中点的数量

并查集:连通块中点的数量

import java.io.*; import java.util.Scanner;public class Main{static int N 100010;static int[] p new int[N]; //存储每个节点的父亲节点,一开始默认p[i]i;static int[] size new int[N]; //存储每个连通块里含有多少个节点static BufferedReader in new BufferedR…
阅读更多...
数学知识第二期 约数

数学知识第二期 约数

前言 约数也是很重要的基础数学知识&#xff0c;希望大家能够完全掌握&#xff01;&#xff01;&#xff01; 一、约数的知识 简介 约数&#xff0c;又称因数。整数a除以整数b(b≠0) 除得的商正好是整数而没有余数&#xff0c;就说a能被b整除&#xff0c;或b能整除a。a称为b的…
阅读更多...
【Java与网络6】实现一个自己的HTTP浏览器

【Java与网络6】实现一个自己的HTTP浏览器

前面我们讨论了HTTP协议的基本结构和Socket编程的基本原理&#xff0c;本文我们来整个大活&#xff1a;自己实现一个简单的浏览器。 目录 1.主线程循环体 2.readHostAndPort()方法的实现 3.readHttpRequest()方法的实现 4.sendHttpRequest()方法的实现 5.readHttpRespons…
阅读更多...
vector迭代器失效

vector迭代器失效

目录 迭代器失效的场景 insert插入元素时迭代器失效 erase删除元素时迭代器失效 本期我们主要进行vector迭代器失效问题的讨论。 迭代器失效的场景 insert插入元素时迭代器失效 先看代码&#xff1a; iterator insert(iterator pos, T val){assert(pos > _start);ass…
阅读更多...
不知道如何批量处理图片

不知道如何批量处理图片

你是否曾经遇到过需要批量处理大量图片的情况&#xff1f;例如&#xff0c;需要将多张图片转换为统一格式、调整大小或进行美化处理。这种时候&#xff0c;如果一张张手动处理&#xff0c;不仅效率低下&#xff0c;还容易出错。那么&#xff0c;有没有一种方法可以快速、准确地…
阅读更多...
web前端项目-动画特效【附源码】

web前端项目-动画特效【附源码】

文章目录 一&#xff1a;赛车游戏动画HTML源码&#xff1a;JS源码&#xff1a;CSS源码&#xff1a;&#xff08;1&#xff09;normalize.css&#xff08;2&#xff09;style.css 二&#xff1a;吉普车动画演示HTML源码&#xff1a;CSS源码&#xff1a;&#xff08;1&#xff09…
阅读更多...
matlab对负数开立方根得到虚数的解决方案

matlab对负数开立方根得到虚数的解决方案

问题描述&#xff1a;在matlab中&#xff0c;对负数开立方根&#xff0c;不出意外你将得到虚数。 例如 − 27 3 \sqrt[3]{-27} 3−27 ​&#xff0c;我们知道其实数解是-3&#xff0c;但在matlab中的计算结果如下&#xff1a; 问题原因&#xff1a;matlab中的立方根运算是在…
阅读更多...
仅使用 Python 创建的 Web 应用程序（前端版本）第08章_商品详细

仅使用 Python 创建的 Web 应用程序（前端版本）第08章_商品详细

在本章中，我们将实现一个产品详细信息页面。 完成后的图像如下。 Model、MockDB、Service都是在产品列表页实现的，所以创建步骤如下。 No分类内容1Page定义PageId并创建继承自BasePage的页面类2Application将页面 ID 和页面类对添加到 MultiPageApp 的页面中Page：定义PageI…
阅读更多...
项目管理平台

项目管理平台

技术架构&#xff1a; MySQL、Servlet、JSP 功能模块&#xff1a; 从管理员角度看: 用户登入系统后&#xff0c;可以修改管理员的密码。同时具有以下功能&#xff1a; 1、管理员可以管理具体项目信息。 2、管理员可以管理项目经费信息。 3、管理员可以管理项目资源信息。 4、…
阅读更多...
确定软件项目范围基准 5个重点

确定软件项目范围基准 5个重点

软件项目范围基准明确了项目的边界、目标和主要交付成果&#xff0c;有助于提高项目成本、进度和资源估算的准确性&#xff0c;便于实施项目控制&#xff0c;而且还可以帮助我们清楚分派责任&#xff0c;防止范围蔓延&#xff0c;从而提升项目的成功率。 如果没有明确确定范围基…
阅读更多...
Hive实战 —— 电商数据分析(全流程详解 真实数据)

Hive实战 —— 电商数据分析(全流程详解 真实数据)

目录 前言需求概述数据清洗数据分析一、前期准备二、项目1. 数据准备和了解2.确定数据粒度和有效列3.HDFS创建用于上传数据的目录4.建库数仓分层 5.建表5.1近源层建表5.2. 明细层建表为什么要构建时间维度表&#xff1f;如何构建时间维度表&#xff1f; 5.3 轻聚层建表6. 指标数…
阅读更多...
transformer架构的理解

transformer架构的理解

一、transformer 架构 如上图所示&#xff0c;transformer&#xff08;形状像变压器&#xff1f;或者翻译成变形金刚&#xff0c;由不同模块拼装而成&#xff09;的架构左边是n个结构体相同的编码器&#xff08;例如&#xff0c;原论文是6个编码器的串联&#xff09;&#xff0…
阅读更多...
第6章 python深度学习—第6章（波斯美女）

第6章 python深度学习—第6章（波斯美女）

第6章 深度学习用于文本和序列 6.1　处理文本数据 与其他所有神经网络一样&#xff0c;深度学习模型不会接收原始文本作为输入&#xff0c;它只能处理数值张量。 文本向量化&#xff08;vectorize&#xff09;是指将文本转换为数值张量的过程。它有多种实现方法。 将文本分割…
阅读更多...
迪文串口屏文本显示的使用

迪文串口屏文本显示的使用

一、使用背景 由于迪文屏的数据变量显示功能不能显示字母类等字符&#xff0c;比如屏幕上要显示期日时间格式为2024-1-27 11:22:20&#xff0c;则不适合用数据变量显示&#xff0c;此时可以使用文本显示功能。 二、实现过程 1、首先查看迪文屏的使用手册DGUSII 应用开发指南…
阅读更多...
两个近期的计算机领域国际学术会议（软件工程、计算机安全）：欢迎投稿

两个近期的计算机领域国际学术会议（软件工程、计算机安全）：欢迎投稿

近期&#xff0c;受邀担任两个国际学术会议的Special session共同主席及程序委员会成员&#xff08;TPC member&#xff09;&#xff0c;欢迎广大学界同行踊跃投稿&#xff0c;分享最新研究成果。期待这个夏天能够在夏威夷檀香山或者加利福尼亚圣荷西与各位学者深入交流。 SERA…
阅读更多...
【投稿优惠|EI优质会议】2024年材料化学与清洁能源国际学术会议(IACMCCE 2024)

【投稿优惠|EI优质会议】2024年材料化学与清洁能源国际学术会议(IACMCCE 2024)

【投稿优惠|优质会议】2024年材料化学与清洁能源国际学术会议(IACMCCE 2024) 2024 International Conference Environmental Engineering and Mechatronics Integration(ICEEMI 2024) 一、【会议简介】 随着全球能源需求的不断增长&#xff0c;清洁能源的研究与应用成为了国际…
阅读更多...
【leetcode题解C++】144. 94. 145.二叉树前序、中序、后序遍历 and 102.二叉树的层序遍历

【leetcode题解C++】144. 94. 145.二叉树前序、中序、后序遍历 and 102.二叉树的层序遍历

144. 二叉树前序遍历 给出一个根节点&#xff0c;返回前中后序遍历的结果的。 示例 1&#xff1a; 输入&#xff1a;root [1,null,2,3] 输出&#xff1a;[1,2,3]示例 2&#xff1a; 输入&#xff1a;root [] 输出&#xff1a;[]示例 3&#xff1a; 输入&#xff1a;root…
阅读更多...
vue3 npm i 一直卡到不动

vue3 npm i 一直卡到不动

一. 首先node 版本要18.0及以上 查看node版本并安装指定版本 二. 查看npm镜像源以及指定安装npm的镜像 三. 删除项目中的package-lock.json文件 最好是把node_modules安装包也删除掉&#xff0c;然后npm i 就可以了
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023