go并发编程基础-channel(代码片段)

天门道人 天门道人     2022-11-30     519

关键词:

协程(Goroutine)

Go 语言中没有线程的概念,只有协程,也称为 goroutine。相比线程来说,协程更加轻量,一个程序可以随意启动成千上万个 goroutine。

goroutine 被 Go runtime 所调度,这一点和线程不一样。也就是说,Go 语言的并发是由 Go 自己所调度的,自己决定同时执行多少个 goroutine,什么时候执行哪几个。这些对于我们开发者来说完全透明,只需要在编码的时候告诉 Go 语言要启动几个 goroutine,至于如何调度执行,我们不用关心。

要启动一个 goroutine 非常简单,Go 语言为我们提供了 go 关键字,相比其他编程语言简化了很多,如下面的代码所示:

func main() 
   go func() 
       fmt.Print("我是新创建的协程")
   ()

go 关键字后跟一个方法或者函数的调用,就可以启动一个 goroutine

协程之间通信(channel)

Go 语言提供的 channel(通道)来解决这个问题

声明一个 channel

ch:=make(chan string)

其中 chan 是一个关键字,表示是 channel 类型。
后面的 string 表示 channel 里的数据是 string 类型。

通过 channel 的声明也可以看到,chan 是一个集合类型。

定义好 chan 后就可以使用了,一个 chan 的操作只有两种:发送和接收

  1. 接收:获取 chan 中的值,操作符为 <- chan。
  2. 发送:向 chan 发送值,把值放在 chan 中,操作符为 chan <-。

注意:这里注意发送和接收的操作符,都是 <- ,只不过位置不同。接收的 <- 操作符在 chan 的左侧,发送的 <- 操作符在 chan 的右侧。

使用实例1:无缓冲channel(同步channel)

如果发送方一直没有发送数据,则接收方会一直阻塞,使用 make 创建的 chan 就是一个无缓冲 channel,它的容量是 0,不能存储任何数据。所以无缓冲 channel 只起到传输数据的作用,数据并不会在 channel 中做任何停留。这也意味着,无缓冲 channel 的发送和接收操作是同时进行的,它也可以称为同步 channel

func TestChannelWithNoBuffer(t *testing.T) 
   ch := make(chan int)
   go func() 
      ch <- 1
   ()
   t.Log("我是main gorountie")
   go func() 
      v := <-ch
      t.Log("获得数据", v)
   ()

使用实例2:有缓冲channel

有缓冲 channel 类似一个可阻塞的队列,内部的元素先进先出。通过 make 函数的第二个参数可以指定 channel 容量的大小,进而创建一个有缓冲 channel,如下面的代码所示:

cacheCh:=make(chan int,5)

创建了一个容量为 5 的 channel,内部的元素类型是 int,也就是说这个 channel 内部最多可以存放 5 个类型为 int 的元素

一个有缓冲 channel 具备以下特点:

  1. 有缓冲 channel 的内部有一个缓冲队列;
  2. 发送操作是向队列的尾部插入元素,如果队列已满,则阻塞等待,直到另一个 goroutine 执行,接收操作释放队列的空间;
  3. 接收操作是从队列的头部获取元素并把它从队列中删除,如果队列为空,则阻塞等待,直到另一个 goroutine 执行,发送操作插入新的元素。
func TestChannelWithBuffer(t *testing.T) 
   ch := make(chan string, 10)
   go func() 
      fmt.Println("balabala")
      ch <- "goroutine 完成"
   ()
   fmt.Println("我是main goroutine")
   ch <- "main goroutine 输入的值"
   v := <-ch
   fmt.Println("等待,接收到channel中的值:", v)

关闭 channel

channel 还可以使用内置函数 close 关闭

close(cacheCh)

如果一个 channel 被关闭了,就不能向里面发送数据了,如果发送的话,会引起 painc 异常。但是还可以接收 channel 里的数据,如果 channel 里没有数据的话,接收的数据是元素类型的零值。

多路复用:select+channel

func TestSelectChannel(t *testing.T) 
   fir := make(chan int)
   sec := make(chan int)
   tir := make(chan int)
   go func() 
      fir <- 1
   ()
   go func() 
      sec <- 2
   ()
   go func() 
      tir <- 3
   ()
   select 
     case filePath := <-fir:
        t.Log(filePath)
     case filePath := <-sec:
        t.Log(filePath)
     case filePath := <-tir:
        t.Log(filePath)
   

整体结构和 switch 非常像,都有 case 和 default,只不过 select 的 case 是一个个可以操作的 channel。多路复用可以简单地理解为,N 个 channel 中,任意一个 channel 有数据产生,select 都可以监听到,然后执行相应的分支,接收数据并处理
在 Go 语言中,提倡通过通信来共享内存,而不是通过共享内存来通信,其实就是提倡通过 channel 发送接收消息的方式进行数据传递,而不是通过修改同一个变量。所以在数据流动、传递的场景中要优先使用 channel,它是并发安全的,性能也不错。

并发编程如果用channel解决并发问题?(代码片段)

...河系】期待你的关注。未来大家一起加油啊~前言什么是Channel?在Go语言基础中应该就学过Channel,那个时候应该都认为只是一个基础类型,是一个管道一样类似的东西,方便快速读写操作,但是Channel在并发中... 查看详情

go-并发编程基础(goroutinechannelselect等)(代码片段)

目录概念协程goroutinegoroutine调度-MPG模式通道Channel数据结构声明&初始化发送与接收遍历和关闭单方向的channelchannel中的channel常见错误time与select超时时间间隔概念并发:指宏观上在一段时间内能同时运行多个程序,微观... 查看详情

并发编程如何用channel解决并发问题?(代码片段)

...河系】期待你的关注。未来大家一起加油啊~前言什么是Channel?在Go语言基础中应该就学过Channel,那个时候应该都认为只是一个基础类型,是一个管道一样类似的东西,方便快速读写操作,但是Channel在并发中... 查看详情

go语言基础之并发(代码片段)

...调度完成,而线程是由操作系统调度完成。Go语言还提供channel在多个goroutine间进行通信。goroutine和channel是Go语言秉承的CSP(CommunicatingSequentialProcess)并发模式的重要实现基础。goroutine在java/c++中我们要实现并发编程的时候,我们... 查看详情

go语言基础之并发(代码片段)

...调度完成,而线程是由操作系统调度完成。Go语言还提供channel在多个goroutine间进行通信。goroutine和channel是Go语言秉承的CSP(CommunicatingSequentialProcess)并发模式的重要实现基础。goroutine在java/c++中我们要实现并发编程的时候,我们... 查看详情

09.go语言并发(代码片段)

...调度完成,而线程是由操作系统调度完成。Go语言还提供channel在多个goroutine间进行通信。goroutine和channel是Go语言秉承的CSP(CommunicatingSequentialProcess)并发模式的重要实现基础。本章中,将详细为大家讲解goroutine和channel及相关特... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——使用channel收发数据(代码片段)

创建channel之后,我们可以使用channel进行数据收发操作。使用channel发送(填充)数据使用特殊的操作符<-,把数据通过channel发送。格式通道变量<-值通道变量是上文通过make创建的通道实例;值可以是变量... 查看详情

19.go语言基础之并发(代码片段)

...)调度完成,而线程是由操作系统调度完成。Go语言还提供channel在多个goroutine间进行通信。goroutine和channel是Go语言秉承的CSP(CommunicationSequentialProcess)并发模式的重要实现基础。1.2goroutine在java/Python中,我们实现并发编程的时候,... 查看详情

golang并发编程之channel(代码片段)

一、概念channel是golang语言级别提供的协程(goroutine)之间的通信方式。goroutine运行在相同的地址空间,因此访问共享内存必须做好同步。那么goroutine之间如何进行数据的通信呢,Go提供了一个很好的通信机制channel。channel可以与Unixs... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——在多个goroutine之间通信的管道(代码片段)

...对内存加锁,这会增加额外的时间开销。go使用通道channel来实现goroutine之间的通信。在食堂、地铁站等公共场所, 查看详情

go_csp并发模型(代码片段)

...代提出的,用于描述两个独立的并发实体通过共享的通讯channel(管道)进行通信的并发模型。相对于Actor模型,CSP中channel是第一类对象,它不关注发送消息的实体,而关注与发送消息时使用的channel。严格来说,CSP是一门形式语言... 查看详情

go语言基础之并发goroutinechan(代码片段)

...uot;fmt""sync")varwgsync.WaitGroupfuncmain()wg.Add(2)gonobufChannel()//不带缓冲区的初始化gobufChannel()//有缓冲区的通道wg.Wait()//不带缓冲区的初始化funcnobufChannel()deferwg.Done()channel1:=make(chanint)gofunc()x:=<-channel1fmt.Println("channel里取... 查看详情

go的通道channel(代码片段)

1、前言作为Go语言最有特色的数据类型,通道(channel)完全可以与goroutine(也可称为go程)并驾齐驱,共同代表Go语言独有的并发编程模式和编程哲学。Don’tcommunicatebysharingmemory;sharememorybycommunicating.(... 查看详情

go的通道channel(代码片段)

1、前言作为Go语言最有特色的数据类型,通道(channel)完全可以与goroutine(也可称为go程)并驾齐驱,共同代表Go语言独有的并发编程模式和编程哲学。Don’tcommunicatebysharingmemory;sharememorybycommunicating.(... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——各种各样的通道(代码片段)

单向通道在声明通道时,我们可以设置只发送或只接收。这种被约束操作方向的通道称为单向通道。声明单向通道只发送:chan<-,只接收:<-chanvar通道实例chan<-元素类型//只发送数据var通道实例<-chan元素... 查看详情

云原生时代崛起的编程语言go并发编程实战(代码片段)

...初步认识。@目录概述基础理论并发原语协程-Goroutine通道-Channel多路复用-Select通道使用超时-Timeout非阻塞通道操作关闭通道通道迭代定时器-TimerAndTicker工作池-WorkerPools等待组-WaitGroup原子操作-Atomic互斥锁-Mutex读写互斥锁-RWMutex有状... 查看详情

go并发编程:协程gorotinechannel锁(代码片段)

...e创建多协程异常捕获recover捕获范围绑定recover创建goroutineChannel什么是Channel?Channel初始化Channel操作无缓冲的channel有缓冲的channel双向channel和单向channel实现并发锁Syncsync.WaitGroupsync.Oncesync.Lock:锁sync.Mutex:互斥锁sync.RWMutex:读写锁... 查看详情

go语言自学系列|golang并发编程之channel的遍历(代码片段)

视频来源:B站《golang入门到项目实战[2021最新Go语言教程,没有废话,纯干货!持续更新中...]》一边学习一边整理老师的课程内容及试验笔记,并与大家分享,请移步至知乎网站,谢谢支持!附上... 查看详情