go并发学习笔记
包含了go学习笔记,含有channel的基础学习,编写数字的平方,如何成组的合并channel,如何优雅的关闭退出并发协程,通道阻塞情况分析,channel与哪些变成情况,可谓是收藏好文.
文章目录
- 并发1:channel的基础学习
- 并发2:编写数字的平方
- 并发3:组装式编写数字的平方
- 并发4:如何关闭退出并发协程
- 并发5:通道阻塞情况
- 并发5:channel情况汇总
并发1:channel的基础学习
func main() {ch := make(chan int, 2)ch <- 1ch <- 2elem, ok := <-chif ok != true {fmt.Println("channel closed")}fmt.Println(elem)
}
一个从channel里读,一个从channel里写
func main() {syncChan1 := make(chan struct{}, 1)syncChan2 := make(chan struct{}, 2)go func() {<-syncChan1fmt.Println("receive a sync signal and wait a second...[receiver]")time.Sleep(time.Second)for {if elem, ok := <-strChan; ok {fmt.Println("Received:", elem, "[receiver]")} else {break}}fmt.Println("stopped [receiver]")syncChan2 <- struct{}{}}()go func() {for _, elem := range []string{"a", "b", "c", "d"} {strChan <- elemfmt.Println("sent:", elem, "[sender]")if elem == "c" {syncChan1 <- struct{}{} //唤醒接收的go携程,fmt.Println("sent a sync signal:", elem, "[sender]")}}fmt.Println("ait 2 seconds...[sender]")time.Sleep(time.Second * 2)close(strChan)syncChan2 <- struct{}{}}()<-syncChan2<-syncChan2
}
赋值写入
type Counter struct {count int
}var mapChan2 = make(chan map[string]*Counter, 1)func (counter *Counter) String() string {return fmt.Sprintf("counter:%d", counter.count)
}
func main() {syncChan := make(chan struct{}, 2)go func() {for {if elem, ok := <-mapChan2; ok {counter := elem["count"]counter.count++} else {break}}fmt.Println("stopped [receiver]")syncChan <- struct{}{}}()go func() {countMap := map[string]*Counter{"count": &Counter{},}for i := 0; i < 5; i++ {mapChan2 <- countMaptime.Sleep(time.Millisecond)fmt.Printf("The count map::%v [sender]\n", countMap)}close(mapChan2)syncChan <- struct{}{}}()<-syncChan<-syncChan
}
用struct进行通信
func main() {dataChan := make(chan int, 5)syncChan1 := make(chan struct{}, 1)syncChan2 := make(chan struct{}, 2)go func() {<-syncChan1for {if elem, ok := <-dataChan; ok {fmt.Printf("Received:%d [receiver]\n]", elem)} else {break}}fmt.Println("Done [receiver]")syncChan2 <- struct{}{}}()go func() {for i := 0; i < 5; i++ {dataChan <- ifmt.Printf("Sent:%d [sender]\n", i)}close(dataChan)syncChan1 <- struct{}{}syncChan2 <- struct{}{}}()<-syncChan2<-syncChan2
}
用select case进行读取
func main() {chanCap := 5intChan := make(chan int, chanCap)for i := 0; i < chanCap; i++ {select {case intChan <- 1:case intChan <- 2:case intChan <- 3:}}for i := 0; i < chanCap; i++ {fmt.Println(<-intChan)}
}
并发2:编写数字的平方
func producer(nums ...int) <-chan int {out := make(chan int)go func() {defer close(out)for _, n := range nums {out <- n}}()return out
}func square(inCh <-chan int) <-chan int {out := make(chan int)go func() {defer close(out)for n := range inCh {out <- n * n}}()return out}func main() {in := producer(1, 2, 3, 4, 5, 6)out := square(in)for ret := range out {fmt.Println(ret)}fmt.Println("done")
}
并发3:组装式编写数字的平方
func producer(nums ...int) <-chan int {out := make(chan int)go func() {defer close(out)for _, n := range nums {out <- n}}()return out
}func square(inCh <-chan int) <-chan int {out := make(chan int)go func() {defer close(out)for n := range inCh {out <- n * n}}()return out}func merge(cs ...<-chan int) <-chan int {out := make(chan int)var wg sync.WaitGroupcollect := func(in <-chan int) {defer wg.Done()for n := range in {out <- n}}wg.Add(len(cs))for _, c := range cs {go collect(c)}go func() {wg.Wait()close(out)}()return out}
func main() {in := producer(1, 2, 3, 4, 5, 6)c1 := square(in)c2 := square(in)c3 := square(in)for ret := range merge(c1, c2, c3) {fmt.Printf("%3d ", ret)}fmt.Println("\ndone")
}
并发4:如何关闭退出并发协程
文章链接:退出
- 使用for-range退出
- 使用,ok退出
- 使用退出通道退出
并发5:通道阻塞情况
// 场景1
// 通道中无数据,但执行读通道func ReadNoDataFromNoBufCh() {noBufCh := make(chan int)<-noBufCh //通道中没数据,你还读,必然阻塞fmt.Println("read from no buffer channel success")}//场景2
//通道中无数据,向通道中写数据,但无协程读取func WriteNoBufCh() {ch := make(chan int)ch <- 1 //通道中无数据,向通道写数据,但无协程读取fmt.Println("write to no buffer channel success")
}//场景3
//通道的缓存中无数据但执行读通道func ReaNoDataFromBufCh() {noBufCh := make(chan int, 1)<-noBufCh //通道中没数据,你还读,必然阻塞fmt.Println("ReaNoDataFromBufCh")}//场景4
//通道缓存已经占满,向通道写数据,但无协程读func WriteBufChButFull() {ch := make(chan int, 1)ch <- 1ch <- 2 //通道缓存已经占满,向通道写数据,但无协程读fmt.Println("WriteBufChButFull")
}
并发5:channel情况汇总
场景 | 原理 | 用法 |
---|---|---|
需要不断从channel读取数据时 | 该方法,当channel关闭时,for循环自动退出,可以防止读取已经关闭的channel | for x := range ch {} |
v,ok := <- ch + select 操作判断channel是否关闭 | ok为true,读到数据,ok为false,没读到数据 | v,ok := <- ch + select |
需要对多个通道进行同时处理,但只处理最先发生的channel时 | select 可以同时监视多个通道的情况,只处理未阻塞的case,当通道为nil时,对应的case永远为阻塞,无论读写,特殊关注:普通情况下,对nil的通道写操作是要panic的 | select |
如果协程只读或只写 | 双向通道变成单向通道 | 单向通道只能只读或只写 |
异步 | 有缓冲通道可供多个协程同时处理,在一定程度可提高并发性 | make(chan int,10) |
需要超时控制的操作 | 使用select 和time.After ,看操作和定时哪个先返回,处理先完成的,就达到了超时控制的效果 | case <- time.After() |
并不希望在channel的读写上浪费时间 | 是为操作加上超时的扩展,这里的操是channel的读或写 | case <-time.After() |
退出时,显示通道所有协程退出 | 所有读ch协程都会收到close(ch)的信号 | 使用close(ch)关闭所有下游协程 |
使用channel传递信号,而不是传递数据时 | 没数据需要传递时,传递空struct | 使用chan struct{} 作为信号channel |
使用channel传递结构体数据时 | channel本质上传递的是数据的拷贝,拷贝的数据越小传输效率越高,传递结构体指针,比传递结构体更高效 | 使用channel传递结构体的指针而非结构体 |
用来获取结果 | channel可以用来传递变量,channel自身也是变量,可以传递自己 | 使用channel传递channel |
相关文章:
go并发学习笔记
包含了go学习笔记,含有channel的基础学习,编写数字的平方,如何成组的合并channel,如何优雅的关闭退出并发协程,通道阻塞情况分析,channel与哪些变成情况,可谓是收藏好文. 文章目录 并发1:chann…...

DeepSeek V3 源码:从入门到放弃!
从入门到放弃 花了几天时间,看懂了DeepSeek V3 源码的逻辑。源码的逻辑是不难的,但为什么模型结构需要这样设计,为什么参数需要这样设置呢?知其然,但不知其所以然。除了模型结构以外,模型的训练数据、训练…...
关于C++数据类型char的类型是整数的思考
学习数据类型时,整数类型中有一个特殊的类型char,可以使用字符来为其赋,也可以用整数来为其赋值,这是怎么一回事?其实任何类型,在计算机的内存中,在最小的存储单元比特中,内部只有0或…...

手写识别革命:Manus AI如何攻克多语言混合识别难题(二)
一、多语种特征分离:对抗训练与解耦表示 1. 梯度反转层(GRL)实现语言无关特征提取 class GradientReversalFn(Function):staticmethoddef forward(ctx, x, alpha):ctx.alpha alphareturn x.view_as(x)staticmethoddef backward(ctx, grad_…...

windows:curl: (60) schannel: SEC_E_UNTRUSTED_ROOT (0x80090325)
目录 1. git update-git-for-windows 报错2. 解决方案2.1. 更新 CA 证书库2.2. 使用 SSH 连接(推荐)2.3 禁用 SSL 验证(不推荐) 1. git update-git-for-windows 报错 LenovoLAPTOP-EQKBL89E MINGW64 /d/YHProjects/omni-channel-…...
typedef 和 using 有什么区别?
在 C 编程中,类型别名(Type Aliases)是为已有类型定义新名称的一种机制,能够显著提升代码的可读性和可维护性。C 提供了两种工具来实现这一功能:传统的 typedef 和 C11 引入的 using 关键字。 概念 类型别名本质上是为…...

【Java学习笔记】三、运算符,表达式、分支语句和循环语句
运算符与表达式 算数运算符与算数表达式 加减运算符 操作数:2结合方向:从左到右优先级:4级 乘(*)、除(/)和取余(%)运算符 操作数:2结合方向:从左到右优先…...
广度优先遍历(BFS):逐层探索的智慧
引言:什么是广度优先遍历? 广度优先遍历(BFS)是一种用于遍历或搜索树(Tree)和图(Graph)结构的算法。其核心思想是逐层访问节点,先访问离起点最近的节点,再逐…...
网络HTTP
HTTP Network Request Library A Retrofit-based HTTP network request encapsulation library that provides simple and easy-to-use API interfaces with complete network request functionality. 基于Retrofit的HTTP网络请求封装库,提供简单易用的API接口和完…...
(七)企业级高性能 WEB 服务 - HTTPS 加密
在当今互联网时代,数据安全成为了每个企业和开发者必须关注的重点。尤其是对于Web服务来说,如何保障用户数据的安全传输是至关重要的。本文将深入探讨HTTPS加密的原理、Nginx的HTTPS配置,以及如何通过Nginx实现高性能的Web服务。 1. HTTPS加密…...

[HTTP协议]应用层协议HTTP从入门到深刻理解并落地部署自己的云服务(2)
标题:[HTTP协议]应用层协议HTTP从入门到深刻理解并落地部署自己的云服务(2) 水墨不写bug 文章目录 一、无法拷贝类(class uncopyable)的设计解释:重要思想:使用示例 二、锁的RAII设计解释重要考虑使用示例 三、基于RAII模式和互斥锁的的日志…...

MySQL(单表)知识点
文章目录 1.数据库的概念2.下载并配置MySQL2.1初始化MySQL的数据2.2注册MYSQL服务2.3启动MYSQL服务2.4修改账户默认密码2.5登录MYSQL2.6卸载MYSQL 3.MYSQL数据模型3.1连接数据库 4.SQL简介4.1SQL的通用语法4.2SQL语句的分类4.3DDL语句4.3.1数据库4.3.2表(创建,查询,修改,删除)4…...

HarmonyOS Next 属性动画和转场动画
HarmonyOS Next 属性动画和转场动画 在鸿蒙应用开发中,动画是提升用户体验的关键要素。通过巧妙运用动画,我们能让应用界面更加生动、交互更加流畅,从而吸引用户的注意力并增强其使用粘性。鸿蒙系统为开发者提供了丰富且强大的动画开发能力&…...

使用Node.js从零搭建DeepSeek本地部署(Express框架、Ollama)
目录 1.安装Node.js和npm2.初始化项目3.安装Ollama4.下载DeepSeek模型5.创建Node.js服务器6.运行服务器7.Web UI对话-Chrome插件-Page Assist 1.安装Node.js和npm 首先确保我们机器上已经安装了Node.js和npm。如果未安装,可以通过以下链接下载并安装适合我们操作系…...
Docker 部署 MongoDB 并持久化数据
Docker 部署 MongoDB 并持久化数据 在现代开发中,MongoDB 作为 NoSQL 数据库广泛应用,而 Docker 则提供了高效的容器化方案。本教程将介绍如何使用 Docker 快速部署 MongoDB,并实现数据持久化,确保数据不会因容器重启或删除而丢失…...
DeepSeek + 沉浸式翻译 打造智能翻译助手
本文详细介绍如何使用 DeepSeek API 沉浸式翻译插件打造个性化翻译助手。 一、DeepSeek API 配置 基础配置 API 基础地址:https://api.deepseek.com需要申请 API Key支持与 OpenAI SDK 兼容的调用方式 可用模型 deepseek-chat:已升级为 DeepSeek-V3&am…...
cdn取消接口缓存
添加cdn后,使用cdn加速域名访问接口 是缓存,不是最新的数据,如果使用局域网则是最新的数据,如果修改配置,确保使用cdn域名请求的接口返回不是缓存 要确保通过CDN加速域名访问接口时返回的是最新的数据,而不…...

字节跳动C++客户端开发实习生内推-抖音基础技术
智能手机爱好者和使用者,追求良好的用户体验; 具有良好的编程习惯,代码结构清晰,命名规范; 熟练掌握数据结构与算法、计算机网络、操作系统、编译原理等课程; 熟练掌握C/C/OC/Swift一种或多种语言ÿ…...

OpenHarmony子系统开发编译构建指导
OpenHarmony子系统开发编译构建指导 概述 OpenHarmony编译子系统是以GN和Ninja构建为基座,对构建和配置粒度进行部件化抽象、对内建模块进行功能增强、对业务模块进行功能扩展的系统,该系统提供以下基本功能: 以部件为最小粒度拼装产品和独…...

MySQL进阶-关联查询优化
采用左外连接 下面开始 EXPLAIN 分析 EXPLAIN SELECT SQL_NO_CACHE * FROM type LEFT JOIN book ON type.card book.card; 结论:type 有All ,代表着全表扫描,效率较差 添加索引优化 ALTER TABLE book ADD INDEX Y ( card); #【被驱动表】࿰…...
基于算法竞赛的c++编程(28)结构体的进阶应用
结构体的嵌套与复杂数据组织 在C中,结构体可以嵌套使用,形成更复杂的数据结构。例如,可以通过嵌套结构体描述多层级数据关系: struct Address {string city;string street;int zipCode; };struct Employee {string name;int id;…...

AI-调查研究-01-正念冥想有用吗?对健康的影响及科学指南
点一下关注吧!!!非常感谢!!持续更新!!! 🚀 AI篇持续更新中!(长期更新) 目前2025年06月05日更新到: AI炼丹日志-28 - Aud…...

K8S认证|CKS题库+答案| 11. AppArmor
目录 11. AppArmor 免费获取并激活 CKA_v1.31_模拟系统 题目 开始操作: 1)、切换集群 2)、切换节点 3)、切换到 apparmor 的目录 4)、执行 apparmor 策略模块 5)、修改 pod 文件 6)、…...
多场景 OkHttpClient 管理器 - Android 网络通信解决方案
下面是一个完整的 Android 实现,展示如何创建和管理多个 OkHttpClient 实例,分别用于长连接、普通 HTTP 请求和文件下载场景。 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas…...

【HarmonyOS 5.0】DevEco Testing:鸿蒙应用质量保障的终极武器
——全方位测试解决方案与代码实战 一、工具定位与核心能力 DevEco Testing是HarmonyOS官方推出的一体化测试平台,覆盖应用全生命周期测试需求,主要提供五大核心能力: 测试类型检测目标关键指标功能体验基…...
解锁数据库简洁之道:FastAPI与SQLModel实战指南
在构建现代Web应用程序时,与数据库的交互无疑是核心环节。虽然传统的数据库操作方式(如直接编写SQL语句与psycopg2交互)赋予了我们精细的控制权,但在面对日益复杂的业务逻辑和快速迭代的需求时,这种方式的开发效率和可…...
系统设计 --- MongoDB亿级数据查询优化策略
系统设计 --- MongoDB亿级数据查询分表策略 背景Solution --- 分表 背景 使用audit log实现Audi Trail功能 Audit Trail范围: 六个月数据量: 每秒5-7条audi log,共计7千万 – 1亿条数据需要实现全文检索按照时间倒序因为license问题,不能使用ELK只能使用…...
鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个医院挂号小程序
一、开发准备 环境搭建: 安装DevEco Studio 3.0或更高版本配置HarmonyOS SDK申请开发者账号 项目创建: File > New > Create Project > Application (选择"Empty Ability") 二、核心功能实现 1. 医院科室展示 /…...
C++ 基础特性深度解析
目录 引言 一、命名空间(namespace) C 中的命名空间 与 C 语言的对比 二、缺省参数 C 中的缺省参数 与 C 语言的对比 三、引用(reference) C 中的引用 与 C 语言的对比 四、inline(内联函数…...

WordPress插件:AI多语言写作与智能配图、免费AI模型、SEO文章生成
厌倦手动写WordPress文章?AI自动生成,效率提升10倍! 支持多语言、自动配图、定时发布,让内容创作更轻松! AI内容生成 → 不想每天写文章?AI一键生成高质量内容!多语言支持 → 跨境电商必备&am…...