iis服务器助手广告广告
返回顶部
首页 > 资讯 > 后端开发 > GO >golang中的CSP并发模型怎么实现
  • 293
分享到

golang中的CSP并发模型怎么实现

2023-06-30 15:06:13 293人浏览 泡泡鱼
摘要

本篇内容介绍了“golang中的CSP并发模型怎么实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1. 相关概念: 用户态:当一个进程在执

本篇内容介绍了“golang中的CSP并发模型怎么实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

1. 相关概念: 

用户态:当一个进程在执行用户自己的代码时处于用户运行态(用户态)

内核态:当一个进程因为系统调用陷入内核代码中执行时处于内核运行态(内核态),引入内核态防止用户态的程序随意的操作内核地址空间,具有一定的安全保护作用。这种保护模式是通过内存页表操作等机制,保证进程间的地址空间不会相互冲突,一个进程的操作不会修改另一个进程地址空间中的数据。

用户态与内核态之间的切换:当在系统中执行一个程序时,大部分时间都是运行在用户态下的,在其需要操作系统帮助完成一些用户态自己没有特权和能力完成的操作时就会切换到内核态。有以下三种方式:

(1)系统调用(中断)用户态进程主动要求切换到内核态的一种方式。

(2)异常cpu运行时如果发生一些没有预知的异常,会触发当前进程切换到处理此异常的内核相关进程中。 

(3)外围设备的中断用户态进程主动要求切换到内核态的一种方式。

协程:又称微线程,纤程。英文名Coroutine。Coroutine是一种运行在用户态的用户线程,类似于 greenthread。协程与线程都相互独立,且有自己的上下文,不同之处在于,协程的切换由其自身控制,而线程的切换收到系统调度。

2. CSP (通信顺序进程) 

CSP模型用来描述两个独立的并发实体通过共享的通讯channel管道进行通信的并发模型。

Golang借用了CSP模型的一些概念如:实体 process,通道 channel,为之实现并发进行了理论支持,实际上并没有完全实现CSP模型的所有理论。process是在go语言上的表现就是goroutine,是实际上并发执行的实体,每个实体之间是通过channel通讯来实现数据共享。

3. channel:同步&传递消息

channel是被单独创建并且可以在进程之间传递,它的通信模式类似于boss-worker模式,一个实体通过将消息发送到channel中,然后又监听这个channel的实体处理,两个实体之间是匿名的,实现原理上其实是一个阻塞的消息队列

具体可以分为:有/无缓存channel,只读channel,只写channel,双向channel

写操作:chan <- value

读操作:<- chan

// Create channel// Unbuffered channelumbuffer_chan := make(chan int)// Buffered channel// Buffer Size = 3buffer_chan := make(chan int,3)// Read-Only channelread_channel := make(&lt;-chan int)// Receive-Only channelreceive_channel := make(chan&lt;- int)

生产者-消费者Sample:

package mainimport (   "fmt"    "time")// 生产者func Producer (queue chan&lt;- int){        for i:= 0; i &lt; 10; i++ {                queue &lt;- i        }}// 消费者func Consumer( queue &lt;-chan int){        for i :=0; i &lt; 10; i++{                v := &lt;- queue                fmt.Println("receive:", v)        }}func main(){        queue := make(chan int, 1)        go Producer(queue)        go Consumer(queue)        time.Sleep(1e9) //让Producer与Consumer完成}

4. goroutine:实际并发执行的实体

在函数或者方法前面加上关键字go,就创建了并发运行的goroutine,eg:

go func (){}func Test(){}// ...go Test()

实例代码:

package main  // 代码包声明语句。import (   "fmt" //系统包用来输出的   "math/rand"   "runtime"   "sync"   "time")func main() {   // 分配一个逻辑处理器给调度器使用   runtime.GOMAXPROCS(1)   // WaitGroup是一个计数信号量,用来记录和维护运行的goroutine,如果当前的wg&gt;0,对应的exit方法就会阻塞   var wg sync.WaitGroup   // 计数加2表示要等待两个goroutine   wg.Add(2)   fmt.Printf("Start Goroutines \n", )   // 声明匿名函数,创建goroutine   go func(){      // 关键字defer会修改函数调用时机,在函数退出时调用Done来通知main函数工作已经完成      defer wg.Done()      for count:=0; count&lt;3; count++ {         for char :='a'; char&lt;'a'+26 ; char++ {            fmt.Printf("%c ", char)         }      }   }()   // 声明匿名函数,创建goroutine   go func() {      // 函数退出时调用Done来通知main函数工作已经完成      defer wg.Done()      for count:=0; count&lt;3; count++ {         for char :='A'; char&lt;'A'+26 ; char++ {            fmt.Printf("%c ", char)         }      }   }()   fmt.Println("Waiting to finish!\n", )   // 等待结束   wg.Wait()   fmt.Println("\nTerminate program! \n", )}

5. golang调度器

OS在物理处理器上调度线程来运行,而golang在逻辑处理器上调度goroutine来运行。每个逻辑处理器都分别绑定到单个操作系统线程。

如果创建一个goroutine并准备运行,这个goroutine就会被放到调度器的全局运行队列中。之后,调度器就会将队列中的goroutine分配给一个逻辑处理器,并放到这个逻辑处理器对应的本地运行队列中。本地运行队列中的goroutine会一直等待,知道自己被分配到相应的逻辑处理器上运行。

eg:

golang中的CSP并发模型怎么实现

其中:

M:Machine,一个M直接关联了一个内核线程。

P:Processor,代表了M所需要的上下文环境,也就是处理用户级代码逻辑的处理器。

G:Goroutine,本质上是一种轻量级的线程--协程。

MPG模型,三者关系的宏观图为:

golang中的CSP并发模型怎么实现

Processor的作用:

当内核线程阻塞的时候,由于上下文的存在,我们能够直接放开其他线程,继续去执行未阻塞的线程,例子如下:

golang中的CSP并发模型怎么实现

如果当前,G0由于I/O,系统调用进行了阻塞,这个时候M0就可以放开其他的线程:

golang中的CSP并发模型怎么实现

M0和G0进行系统调用,等待返回值,上下文P以及routine队列交由M1进行执行。当M0执行系统调用结束后,M0会尝试去steal("偷")一个上下文,如果不成功,M0就把它的G0放到一个全局的运行队列中,然后将自己放到线程池或者转入休眠状态。

Global runqueue是各个上下文P在运行完自己的本地的goroutine runqueue后用来拉取新的goroutine的地方(steal working算法)。此外,P也会周期性的检查Global runqueue上的goroutine,来防止全局上的goroutine因为得不到执行而饿死。

“golang中的CSP并发模型怎么实现”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!

您可能感兴趣的文档:

--结束END--

本文标题: golang中的CSP并发模型怎么实现

本文链接: https://www.lsjlt.com/news/330168.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • golang中的CSP并发模型怎么实现
    本篇内容介绍了“golang中的CSP并发模型怎么实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1. 相关概念: 用户态:当一个进程在执...
    99+
    2023-06-30
  • C#怎么实现CSP并发模型
    这篇文章主要介绍“C#怎么实现CSP并发模型”,在日常操作中,相信很多人在C#怎么实现CSP并发模型问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”C#怎么实现CSP并发模型”的疑惑有所帮助!接下来,请跟着小编...
    99+
    2023-06-29
  • 示例剖析golang中的CSP并发模型
    目录1. 相关概念: 2. CSP (通信顺序进程) 3. channel:同步&传递消息4. goroutine:实际并发执行的实体5. golang调度器1. 相关概念:...
    99+
    2024-04-02
  • Go语言CSP并发模型怎么实现MPG
    这篇文章主要介绍“Go语言CSP并发模型怎么实现MPG”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Go语言CSP并发模型怎么实现MPG”文章能帮助大家解决问题。Golang调度机制golang的g...
    99+
    2023-06-30
  • Go语言CSP并发模型实现MPG
    目录Golang调度机制并发(concurrency)和并行(parallellism)Go的CSP并发模型Go并发模型的实现原理用户级线程模型内核级线程模型两级线程模型Go线程实现...
    99+
    2024-04-02
  • Golang CSP并发机制及使用模型是什么
    这篇文章主要介绍了Golang CSP并发机制及使用模型是什么的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Golang CSP并发机制及使用模型是什么文章都会有所收获,下面我们一起来看看吧...
    99+
    2023-06-30
  • C#代替go采用的CSP并发模型实现
    目录CSP(Communicating sequential processes)在Go中的CSP协程(提升并发的利器)线程线程的开销回归协程协程的目的C#中的协程C#中的CSPGo...
    99+
    2024-04-02
  • Golang并发编程之GMP模型怎么实现
    本文小编为大家详细介绍“Golang并发编程之GMP模型怎么实现”,内容详细,步骤清晰,细节处理妥当,希望这篇“Golang并发编程之GMP模型怎么实现”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。0. 简介传统...
    99+
    2023-07-05
  • Go语言CSP并发模型goroutine及channel底层实现原理
    目录Go的CSP并发模型(goroutine + channel)1、goroutinegoroutine的优点:2、channel无缓存channel有缓存channel3、Go并...
    99+
    2024-04-02
  • golang并发模型怎么使用
    Golang的并发模型是通过goroutine和channel来实现的。1. Goroutine: Goroutine是轻量级的线程...
    99+
    2023-08-23
    golang
  • 分析Go语言中CSP并发模型与Goroutine的基本使用
    目录一、并发实现模型1.1、多进程1.2、多线程1.3、协程二、共享内存与CSP三、Goroutine一、并发实现模型 1.1、多进程 在之前的文章当中我们曾经介绍过,进程是操作系统...
    99+
    2024-04-02
  • Go中的并发模式:CSP与消息传递
    在 go 中进行并发编程时,理解和使用适当的模式至关重要。csp 是一种基于顺序进程的并发模式,使用 goroutine 实现,适合简单的通信。消息传递是一种使用通道作为消息队列进行通信...
    99+
    2024-05-12
    csp 消息传递 并发模式
  • Golang中的并发模型有哪些优势
    Golang中的并发模型有以下优势: 轻量级线程:Golang使用轻量级的goroutine来实现并发,相比于传统的线程模型,g...
    99+
    2024-03-13
    Golang
  • 常用的golang并发模型有哪些
    常用的golang并发模型有以下几种: Goroutine和Channel:Goroutine是轻量级的线程,可以同时运行上千个...
    99+
    2023-10-23
    golang
  • GO并发模型的实现原理是什么
    这篇文章主要介绍了GO并发模型的实现原理是什么的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇GO并发模型的实现原理是什么文章都会有所收获,下面我们一起来看看吧。前言请记住下面这句话:DO NOT COMMUNI...
    99+
    2023-06-30
  • Golang并发模型中的同步与性能优化
    在Golang的并发模型中,同步和性能优化是两个关键的方面。同步指的是协调多个并发操作的执行顺序,以避免数据竞争和不一致性的问题。G...
    99+
    2023-10-08
    Golang
  • 常用的golang并发模型有哪几种
    常用的Golang并发模型有以下几种: 传统的多线程模型:基于线程和锁的并发模型,通过创建多个线程来处理并发任务,并使用锁来保护...
    99+
    2024-02-29
    golang
  • 深入解析Golang的并发编程模型
    Golang作为一种开发高效、简洁的编程语言,具有非常强大的并发编程能力,为开发者提供了丰富的工具和机制来处理并发问题。本文将深入解析Golang的并发编程模型,包括Goroutine...
    99+
    2024-03-01
    模型 golang 并发 go语言
  • golang控制并发数怎么实现
    在Go语言中,可以使用goroutine和channel来实现并发控制。下面是一种常见的实现方式: 创建一个有缓冲的channel...
    99+
    2023-10-21
    golang
  • Java并发中的内存模型
    这篇文章主要讲解了“Java并发中的内存模型”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Java并发中的内存模型”吧!CPU和内存在讲JMM之前,我想先和大家聊聊硬件层面的东西。大家应该都...
    99+
    2023-06-02
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作