Go保证并发安全底层实现详解

 更新时间:2022年09月02日 09:16:32   作者:Sundar84034  
这篇文章主要为大家介绍了Go保证并发安全底层实现详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

引言

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

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

CSP

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

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

Channel的基本使用

package main
import "fmt"
func main() {
	c := make(chan int)
	go func() {
		c <- 1 // 向channel发送数据
	}()
	x := <-c // 从channel中接收数据
	fmt.Println(x)
}

1、通过make(chan int)创建一个int channel(可以在channel初始化时指定缓冲区的大小,例如make(chan int,2),不指定则默认为0)

2、在一个goroutine中,通过c<-1将数据发送到channel中,<-可以理解为数据的流动方向。

3、在主goroutine中通过x := <-c接收channel中的数据,并赋值给x。

channel如何保证并发安全

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

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

channel的底层实现

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

hchan 是 channel 在 golang 中的内部实现

type hchan struct { 
    qcount uint // total data in the queue 
    dataqsiz uint // size of the circular queue 
    buf unsafe.Pointer // points to an array of dataqsiz elements 
    elemsize uint16 
    closed uint32 
    elemtype *_type // element type 
    sendx uint // send index 
    recvx uint // receive index 
    recvq waitq // list of recv waiters 
    sendq waitq // list of send waiters 
    // lock protects all fields in hchan, as well as several 
    // fields in sudogs blocked on this channel. 
    // 
    // Do not change another G's status while holding this lock 
    // (in particular, do not ready a G), as this can deadlock 
    // with stack shrinking. 
    lock mutex 
 } 

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

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

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

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

hchan的所有行为,基本都是围绕bufferwaitq来实现的

waitq

type waitq struct { 
 first *sudog 
 last *sudog 
 } 

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

buffe

buffer使用 ring buffer(环形缓冲区)实现

在hchan中,可以看到 recvxsendx 两个属性,recvx即当前已发送的元素在队列当中的索引位置,sendx 即 当前已接收的元素在队列当中的索引位置。

从 recvx 到 sendx 之间的元素,表示已正常存放入 buffer 中的数据。

Lock

hchan中的lock就是一个互斥锁,channel在发送和接收数据前,都会先进行加锁,待逻辑完成后执行再解锁,来保证并发安全。

以上就是Go保证并发安全底层实现详解的详细内容,更多关于Go并发安全底层实现的资料请关注脚本之家其它相关文章!

相关文章

  • Golang的关键字defer的使用方法

    Golang的关键字defer的使用方法

    这篇文章主要介绍了Golang的关键字defer的使用方法,文章围绕主题展开详细的内容介绍,具有一定的参考价值,需要的小伙伴可以参考一下
    2022-06-06
  • 基于Golang编写一个聊天工具

    基于Golang编写一个聊天工具

    这篇文章主要为大家详细介绍了如何使用 Golang 构建一个简单但功能完善的聊天工具,利用 WebSocket 技术实现即时通讯的功能,需要的小伙伴可以参考下
    2023-11-11
  • 使用os包和flag包实现读取main命令入参

    使用os包和flag包实现读取main命令入参

    这篇文章主要介绍了使用os包和flag包实现读取main命令入参的相关资料,需要的朋友可以参考下
    2015-03-03
  • golang实现webgis后端开发的步骤详解

    golang实现webgis后端开发的步骤详解

    这篇文章主要介绍如何用golang结合postgis数据库,使用gin、grom框架实现后端的MVC的接口搭建,文中有详细的流程步骤及代码示例,需要的朋友可以参考下
    2023-06-06
  • Go 语言sort 中的sortInts 方法

    Go 语言sort 中的sortInts 方法

    这篇文章主要介绍了Go 语言sort 中的sortInts 方法,Go 的 sort 包实现了内置和用户定义类型的排序。我们将首先查看内置函数的排序,西瓦嗯更多相关资料需要的小伙伴可以参考一下
    2022-04-04
  • Go语言中的通道channel详情

    Go语言中的通道channel详情

    这篇文章主要介绍了Go语言中的通道channel,在Go语言中管道类似于一个数据流,每次放入或者取出一部分数据,数据取出后原通道内的数据就删除掉,在linux操作系统中管道会将函数的返回结果作为下一个函数的参数,下文详细内容需要的朋友可以参考下
    2022-02-02
  • 一文详解Go语言中Mutex互斥锁

    一文详解Go语言中Mutex互斥锁

    Golang中的Mutex互斥锁是一种常用的并发控制机制,用于保护共享资源的访问,在本文中,我们将深入探讨Mutex互斥锁的原理、日常使用、锁结构以及运行机制,需要的朋友可以参考下
    2023-12-12
  • Go语言中函数可变参数(Variadic Parameter)详解

    Go语言中函数可变参数(Variadic Parameter)详解

    在Python中,在函数参数不确定数量的情况下,可以动态在函数内获取参数。在Go语言中,也有类似的实现方式,本文就来为大家详细讲解一下
    2022-07-07
  • 一文理解Goland协程调度器scheduler的实现

    一文理解Goland协程调度器scheduler的实现

    本文主要介绍了Goland协程调度器scheduler的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-06-06
  • Golang简单实现http的server端和client端

    Golang简单实现http的server端和client端

    Http 服务是基于 Tcp 的应用层的实现,也是最常见的网络协议之一。本文主要介绍了Golang简单实现http的server端和client端,感兴趣的可以了解一下
    2021-06-06

最新评论