44-Golang中的channel
创始人
2024-06-01 14:49:28
0

Golang中的channel

    • 为什么要使用channel
    • channel的介绍
    • channel的基本使用
      • 定义/声明channel
    • 管道的遍历和关闭
      • channel的关闭
      • channel的遍历
    • goroutine和channel结合
      • 应用实例1
      • 应用实例2
      • 案例
    • 注意事项

为什么要使用channel

前面使用全局变量加锁同步来解决goroutine的通讯,但不完美

  • 1.主线程在等待所有goroutine全部完成时间很难确定,我们这里设置10秒,仅仅是过段
  • 2.如果主线程休眠时间长了,会加长等待时间,如果等待时间短了,可能还有routine处于工作状态,这时也会随主线程的退出而销毁
  • 3.通过全局白能量加锁同步来实现通讯,也并不利用多个协程对全局变量的读写操作
  • 4.上面种种分析都在互换一个新的通讯机制-----channel

channel的介绍

  • 1.channel本质就是一个数据结构-队列
  • 2.数据是先进先出
  • 3.线程安全,多goroutine访问时,不需要加锁,就是说channel本身就是线程安全的
  • 4.channel是有类型的,一个string的channel只能存放string类型数据
    在这里插入图片描述

channel的基本使用

定义/声明channel

var 变量名chan数据类型

举例:

var intChan chan int (intChan用于存放int数据)

var mapChan chan map[int]ssting (mapChan用于存放map[int]string类型)

var perChan chan Person

var perChan2 chan *Person

说明:

channel是引用类型

channel必须初始化才能写入数据,即make后才能使用

管道是有类型的,intChan只能写入整数

package mainimport "fmt"func main() {//演示一下管道的使用//创建一个可以存放三个int类型的俄管道var intChan chan intintChan = make(chan int, 3)//看看intChan是什么fmt.Printf("intChan的值=%v intChan本身的地址=%p\n", intChan, &intChan)//向管道写入数据intChan <- 10num := 211intChan <- num//看看管道的长度和cap(容量)fmt.Printf("channel len = %v cap=%v \n", len(intChan), cap(intChan))//从管道中读取数据var num2 intnum2 = <-intChanfmt.Println("num2=", num2)fmt.Printf("channel len =%v cap=%v \n", len(intChan), cap(intChan))//在没有使用协程的情况下,如果我们管道数据已经全部取出,在取就会报告deadlock
}
/*
intChan的值=0xc00010e080 intChan本身的地址=0xc000006028
channel len = 2 cap=3 
num2= 10              
channel len =1 cap=3  
*/

管道的遍历和关闭

channel的关闭

使用内置函数close可以关闭channel,当channel关闭后,就不能再想channel写数据了,但是仍然可以从给channel读取数据

channel的遍历

channel支持for-range的方式进行遍历

1.在遍历时,如果channel没有关闭,则会出现deadlock的错误

2.在遍历时,如果channel已经关闭,则会出现正常遍历数据,遍历完后,就会退出遍历

package mainimport "fmt"func main() {intChan := make(chan int, 3)intChan <- 100intChan <- 200close(intChan)//这时不能够再写入到channel//intChan <- 300fmt.Println("okk")n1 := <-intChanfmt.Println("n1=", n1)//遍历管道intChan2 := make(chan int, 100)for i := 0; i < 100; i++ {intChan2 <- i * 2 //放入100个数据到管道}// 在遍历时,如果channel没有关闭,责护出现deadlock的错误close(intChan2)for v := range intChan2 {fmt.Println("v=", v)}}

goroutine和channel结合

应用实例1

在这里插入图片描述

在这里插入图片描述

package mainimport ("fmt""time"
)func writeData(intChan chan int) {for i := 1; i < 50; i++ {//放入数据intChan <- ifmt.Println("writeData", i)time.Sleep(time.Second)}close(intChan) //关闭
}//read data
func readData(intChan chan int, exitChan chan bool) {for {v, ok := <-intChanif !ok {break}time.Sleep(time.Second)fmt.Printf("readData读到数据=%v\n", v)}//readData读取完数据后,即任务完成exitChan <- trueclose(exitChan)
}func main() {//创建两个管道intChan := make(chan int, 50)exitChan := make(chan bool, 1)go writeData(intChan)go readData(intChan, exitChan)//time.Sleep(time.Second * 10)for {_, ok := <-exitChanif !ok {break}}
}

应用实例2

如果只是向管道写入数据,而没有读取,就会出现阻塞而dead lock,原因是intChan容量是10,而带点吗writeData会写入50个数据,因此就会阻塞在writeData的ch<-i

案例

在这里插入图片描述

package mainimport "fmt"func putNum(intChan chan int) {for i := 1; i <= 8000; i++ {intChan <- i}//关闭intChanclose(intChan)
}//开启四个协程,从intChan取出数据,并判断是否为素数
//如果是,就放入到primeChan
func primeNum(intChan chan int, primeChan chan int, exitChan chan bool) {//使用for循环var flag boolfor {num, ok := <-intChanif !ok {break}flag = true //假定是素数//判断num是不是素数for i := 2; i < num; i++ {if num%i == 0 { //说明该num不是素数flag = falsebreak}}if flag {//将这个数就放入到primeChanprimeChan <- num}}fmt.Println("有一个primeNum协程因为取不到数据,退出")//这里还不能关闭primeChan//向exitChan写入trueexitChan <- true
}func main() {intChan := make(chan int, 1000)primeChan := make(chan int, 2000) //放入结果//标识退出的管道exitChan := make(chan bool, 4)//开启一个协程,想in特产放入1-8000个数go putNum(intChan)//开启四个协程,从intChan取出数据,并判断是否为素数//如果是,就放入到primeChanfor i := 0; i < 4; i++ {go primeNum(intChan, primeChan, exitChan)}//这里进行主线程处理go func() {for i := 0; i < 4; i++ {<-exitChan}//当我们从exitChan,去出了4个结果,就可以放心关闭primeChanclose(primeChan)}()//遍历primeNum,把结果输出for {res, ok := <-primeChanif !ok {break}//将结果输出fmt.Printf("素数=%d\n", res)}fmt.Println("main线程退出")
}

注意事项

  • 1.channel可以声明为只读,或者只写性质
  • 2.channel只读和只写的最佳实践案例
package mainimport "fmt"func main() {//管道可以声明为只读或者只写//默认情况下,管道是双向的//var chan1 chan int//声明为只写var chan2 chan<- intchan2 = make(chan int, 3)chan2 <- 20//num := <-chan2fmt.Println("chan2=", chan2)//声明为只读var chan3 <-chan intnum2 := <-chan3fmt.Println("num2=", num2)
}
  • 3.使用select可以解决从管道取数据的阻塞问题
  • 4.goroutine中使用recover,解决携程中出现panic,导致程序奔溃问题
    • 说明,如果我们起了一个协程,但是这个协程出现了panic,如果我们没有捕获这个panic,就会造成整个程序崩溃,这是我们可以在goroutine中使用recover来捕获panic,进行处理,这样及时这个协程发生的问题,但是主线程仍然不受影响,

相关内容

热门资讯

魅族降系统安卓13系统,探索无... 你知道吗?最近手机圈里可是炸开了锅,魅族这个品牌竟然悄悄地给自家手机升级了安卓13系统!这可真是让人...
安卓手机查看系统信息,系统信息... 你有没有想过,你的安卓手机里藏着多少秘密?别小看那小小的屏幕,它可是个信息宝库呢!今天,就让我带你一...
安卓7.0系统相机崩溃,原因分... 最近是不是你也遇到了安卓7.0系统相机崩溃的烦恼?别急,让我来给你详细说说这个让人头疼的问题,让你一...
安卓u子系统系统u盘,Andr... 你有没有想过,你的安卓手机里有一个神秘的“U子系统”,它就像一个隐藏的宝藏,等待着你去探索。今天,就...
联想怎么下载安卓系统,安卓系统... 你有没有想过,你的联想手机或者平板,有一天也能装上安卓系统的全新面貌呢?没错,今天就要来手把手教你如...
查老式安卓系统版本,展望未来 你有没有发现,手机里的安卓系统版本有时候就像是个神秘的宝藏,藏着许多不为人知的秘密呢?今天,就让我带...
核酸录入安卓机系统,基于安卓系... 你有没有想过,那些看似简单的核酸检测,背后竟然有这么复杂的“大脑”——安卓机系统?没错,就是那个我们...
高邮苹果刷安卓系统,安卓系统助... 你有没有想过,那些我们平时吃的苹果,竟然也能刷上安卓系统?听起来是不是有点不可思议?没错,今天就要带...
安卓系统的ar眼镜,安卓系统赋... 你有没有想过,未来科技的世界里,眼镜不仅仅是用来看清世界的工具,还能成为你的得力助手?没错,说的就是...
怎样删安卓系统垃圾,揭秘安卓系... 手机里的安卓系统是不是越来越卡了?是不是觉得那些垃圾文件占据了太多空间,让你头疼不已?别急,今天就来...
畅享10安卓系统,畅享智能生活... 你有没有听说啊?最近安卓系统又来了一次大升级,这次可是直接跳到了10版本,听起来是不是很酷炫?没错,...
安卓怎么刷荣耀系统,轻松刷入荣... 你有没有想过,你的安卓手机能不能来点不一样的风采呢?没错,就是刷机!今天,就让我来带你一起探索如何给...
安卓系统游戏占用内存,揭秘内存... 手机里的游戏是不是越来越多了?每次打开,那内存占用简直让人头疼!今天,就让我来和你聊聊安卓系统游戏占...
安卓驱动系统开发,基于安卓驱动... 你有没有想过,你的安卓手机里那些神奇的驱动系统是怎么来的?没错,就是那些让手机能够顺畅运行各种应用的...
安卓更新系统14,系统革新与未... 你知道吗?最近安卓系统又来了一次大变身,那就是安卓更新系统14!这可不是一个小打小闹的更新,而是带来...
安卓手机按键刷系统,轻松实现系... 你有没有想过,你的安卓手机按键居然也能刷系统呢?没错,你没听错!今天,就让我带你一起探索这个神奇的小...
安卓系统电脑下载图片,轻松获取... 你有没有想过,在电脑上下载图片竟然也能变得如此简单?没错,就是那个我们每天都离不开的安卓系统,它现在...
安卓系统电池描述文件,深度解析... 你有没有发现,手机用着用着,电池就有点不给力了?别急,今天就来给你揭秘安卓系统里的那个神秘角色——电...
鸿蒙系统基于安卓内核,融合与创... 你知道吗?最近科技圈里有个大新闻,那就是华为的鸿蒙系统。没错,就是那个让安卓和iOS都黯然失色的操作...
云os系统装安卓,轻松实现安卓... 你有没有想过,你的手机或者平板电脑,其实可以像电脑一样,装上各种各样的操作系统呢?没错,今天就要来聊...