引言

上一部分主要写了锁，本篇主要介绍Channel

channel是Go中非常重要的一个数据类型，它和goroutine紧密相连，是Go的CSP并发模型的重要体现。

CSP

  • CSP 是通信顺序进程（Communicating Sequential Process）的简称，是一种并发编程模型。
  • 简单来说，CSP模型由并发的实体所组成，实体之间通过发送消息进行通信，而发送消息使用的就是通道，即channel。
  • GO实现了CSP部分理论，goroutine对应CSP中的并发执行的实体，channel对应CSP中的channel。

不要通过共享内存来通信，而应该通过通信来共享内存

Channel的基本使用

make(chan int)make(chan int，2)
c<-1<-
x := <-c

channel如何保证并发安全

既然goroutin和channel分别对应csp中的实体和媒介，goroutin之间都是通过chennel来传递数据，那么是如何保证并发安全的呢？

通过阅读源码可以发现，channel内部是使用Mutext互斥锁来保证的（ 之前也有人提出CAS无锁Channel的实现，但因为无锁Channel在多核测试中的表现和没有满足FIFO的特性等原因，该提案目前是搁浅状态）关于无锁channel的讨论

channel的底层实现

channel的核心源码位于runtime包的chan.go中。

hchan 是 channel 在 golang 中的内部实现

hchan的所有属性大体可以分为3类

1、buffer相关属性，当channel中的缓冲区大小不为0时，buffer中存放了待接收的数据。

2、waitq相关属性，即recvq和sendq，可以理解为一个标准的FIFO队列，recvq是等待接收数据的goroutine，sendq是等待发送数据的goroutine。

3、其它，例如lock（互斥锁）、elemtype（元素类型）、closed（channel 是否关闭，== 0 代表未 closed）

hchan的所有行为，基本都是围绕buffer和waitq来实现的

waitq

waitq是一个双向链表，里面保存了goroutine。

buffe

buffer使用 ring buffer（环形缓冲区）实现

recvxsendxrecvxsendx
recvxsendx

Lock

lock
您可能感兴趣的文章: