網(wǎng)站首頁 編程語言 正文
一、Go語言中Goroutine的基本原理
Go語言里的并發(fā)指的是能讓某個函數(shù)獨立于其他函數(shù)運行的能力。
Go語言的goroutine是一個獨立的工作單元,
Go 語言的并發(fā)同步模型來自一個叫作通信順序進程(Communicating Sequential Processes,CSP)的范型(paradigm)。
CSP 是一種消息傳遞模型,通過在goroutine 之間傳遞數(shù)據(jù)來傳遞消息,而不是對數(shù)據(jù)進行加鎖來實現(xiàn)同步訪問。消息的傳遞通過Go語言中的Channel(通道)來實現(xiàn)。
進程(process) 看作一個包含了應用程序在運行中需要用到和維護的各種資源的容器。
線程(Thread)是一個執(zhí)行空間,這個空間會被操作系統(tǒng)調(diào)度來運行函數(shù)中所寫的代碼。
每個進程至少包含一個線程,每個進程的初始線程被稱作主線程。因為執(zhí)行這個線程的空間是應用程序的本身的空間,所以當主線程終止時,應用程序也會終止。
下圖就是進程和線程的簡要關系。
補充:句柄是什么?
我的理解句柄就是給用戶操作內(nèi)核資源的指針,指向指針的指針。【把手】和【門】的關系,使用們把手能轉(zhuǎn)動整個門(系統(tǒng)資源)
操作系統(tǒng)會在物理處理器上調(diào)度線程來運行,而Go 語言的運行時會在邏輯處理器上調(diào)度goroutine來運行。每個邏輯處理器都分別綁定到單個操作系統(tǒng)線程。下面我們就來簡單描述一下goroutine執(zhí)行的流程。
首先來了解一下操作系統(tǒng)線程、邏輯處理器和本地運行隊列
全局運行隊列:剛創(chuàng)建的goruntine會被安排到這里面,通過一些調(diào)度算法,分配給邏輯處理器
操作系統(tǒng)線程:這個就是傳統(tǒng)意義上的線程,用于具體goroutine的執(zhí)行,他會和一個邏輯器進行綁定
邏輯處理器:里面維護著一個本地的隊列,用于本地隊列里面goroutine的調(diào)度
本地運行隊列:裝載著待執(zhí)行的goruntine
支撐整個調(diào)度器的主要有4個重要結(jié)構,分別是M、G、P、Sched,前三個定義在runtime.h中,Sched定義在proc.c中。
- Sched結(jié)構就是調(diào)度器,它維護有存儲M和G的隊列以及調(diào)度器的一些狀態(tài)信息等。
- M代表內(nèi)核級線程,一個M就是一個線程,goroutine就是跑在M之上的;M是一個很大的結(jié)構,里面維護小對象內(nèi)存cache(mcache)、當前執(zhí)行的goroutine、隨機數(shù)發(fā)生器等等非常多的信息。
- P全稱是Processor,處理器,它的主要用途就是用來執(zhí)行goroutine的,所以它也維護了一個goroutine隊列,里面存儲了所有需要它來執(zhí)行的goroutine,這個P的角色可能有一點讓人迷惑,一開始容易和M沖突,后面重點聊一下它們的關系。
- G就是goroutine實現(xiàn)的核心結(jié)構了,G維護了goroutine需要的棧、程序計數(shù)器以及它所在的M等信息。
整個過程描述:
當創(chuàng)建一個Goroutine的時候,先放到全局隊列當中,然后會把這個Goroutine分配到一個邏輯處理器的本地隊列中,這個邏輯處理器會綁定一個操作系統(tǒng)線程,由這個線程去執(zhí)行Goroutine的代碼。
生動描述:
地鼠(gopher)用小車運著一堆待加工的磚。M就可以看作圖中的地鼠,P就是小車,G就是小車里裝的磚。一圖勝千言啊,弄清楚了它們?nèi)叩年P系,下面我們就開始重點聊地鼠是如何在搬運磚塊的。
1.runqget, 地鼠(M)試圖從自己的小車(P)取出一塊磚(G),當然結(jié)果可能失敗,也就是這個地鼠的小車已經(jīng)空了,沒有磚了。
2.findrunnable, 如果地鼠自己的小車中沒有磚,那也不能閑著不干活是吧,所以地鼠就會試圖跑去工場倉庫取一塊磚來處理;工場倉庫也可能沒磚啊,出現(xiàn)這種情況的時候,這個地鼠也沒有偷懶停下干活,而是悄悄跑出去,隨機盯上一個小伙伴(地鼠),然后從它的車里試圖偷一半磚到自己車里。如果多次嘗試偷磚都失敗了,那說明實在沒有磚可搬了,這個時候地鼠就會把小車還回停車場,然后睡覺休息了。如果地鼠睡覺了,下面的過程當然都停止了,地鼠睡覺也就是線程sleep了。
3.wakep, 到這個過程的時候,可憐的地鼠發(fā)現(xiàn)自己小車里有好多磚啊,自己根本處理不過來;再回頭一看停車場居然有閑置的小車,立馬跑到宿舍一看,你妹,居然還有小伙伴在睡覺,直接給屁股一腳,“你妹,居然還在睡覺,老子都快累死了,趕緊起來干活,分擔點工作。”,小伙伴醒了,拿上自己的小車,乖乖干活去了。有時候,可憐的地鼠跑到宿舍卻發(fā)現(xiàn)沒有在睡覺的小伙伴,于是會很失望,最后只好向工場老板說——”停車場還有閑置的車啊,我快干不動了,趕緊從別的工場借個地鼠來幫忙吧。”,最后工場老板就搞來一個新的地鼠干活了。
4.execute,地鼠拿著磚放入火種歡快的燒練起來。
注: “地鼠偷磚”叫work stealing,一種調(diào)度算法。
到這里,貌似整個工場都正常的運轉(zhuǎn)起來了,無懈可擊的樣子。不對,還有一個疑點沒解決啊,假設地鼠的車里有很多磚,它把一塊磚放入火爐中后,何時把它取出來,放入第二塊磚呢?難道要一直把第一塊磚燒練好,才取出來嗎?那估計后面的磚真的是等得花兒都要謝了。這里就是要真正解決goroutine的調(diào)度,上下文切換問題。
goroutine的阻塞
當一個OS線程M0陷入阻塞時(如下圖),P轉(zhuǎn)而在運行M1,圖中的M1可能是正被創(chuàng)建,或者從線程緩存中取出。
簡單解釋就是,當當前的Goroutine在阻塞,就把他和當前線程綁定,讓當前的線程繼續(xù)執(zhí)行這個Goroutine(就是等待),其他的goroutine隨著邏輯處理器被綁定到另一個線程上,繼續(xù)執(zhí)行。
當阻塞的線程返回時,它必須嘗試取得一個邏輯處理器來運行goroutine,一般情況下,它會從其他的OS線程那里拿一個P過來,如果沒有拿到的話,它就把goroutine放在一個全局運行隊列里,然后自己睡眠(放入線程緩存里)。所有的P也會周期性的檢查global runqueue并運行其中的goroutine,否則global runqueue上的goroutine永遠無法執(zhí)行。
還有就像下面的圖片,左邊的線程一個滿載狀態(tài),一個沒有goroutine,此時的做法就是會進行重新分配,就想右側(cè)圖展示
參考 :https://morsmachine.dk/go-scheduler
二、Go語言中的并發(fā)和并行
并發(fā)是兩個任務可以在重疊的時間段內(nèi)啟動,運行和完成。并行是任務在同一時間運行,例如,在多核處理器上。
并發(fā)是獨立執(zhí)行過程的組合,而并行是同時執(zhí)行(可能相關的)計算。
并發(fā)是一次處理很多事情,并行是同時做很多事情。
- 應用程序可以是并發(fā)的,但不是并行的,這意味著它可以同時處理多個任務,但是沒有兩個任務在同一時刻執(zhí)行。
- 應用程序可以是并行的,但不是并發(fā)的,這意味著它同時處理多核CPU中的任務的多個子任務。
- 應用程序可以即不是并行的,也不是并發(fā)的,這意味著它一次一個地處理所有任務。
- 應用程序可以即是并行的也是并發(fā)的,這意味著它同時在多核CPU中同時處理多個任務。
簡單講:并行就是同時做很多事 并發(fā)就是一堆事情一個時間點來了,然后通過分片等方式感覺像都在執(zhí)行
原文鏈接:https://www.cnblogs.com/dcz2015/p/10106866.html
相關推薦
- 2022-11-27 Git基礎學習之標簽tag的使用詳解_相關技巧
- 2022-07-07 C語言實現(xiàn)順序表的插入刪除_C 語言
- 2022-08-20 Python超細致探究面向?qū)ο骭python
- 2022-12-09 C++筆記-設置cout輸出數(shù)據(jù)的寬度和填充方式_C 語言
- 2022-09-29 基于PyQt5實現(xiàn)一個無線網(wǎng)連接器_python
- 2024-03-07 SpringIoC-基于XML配置方式組件管理
- 2023-07-25 SpringBoot配置AOP
- 2022-08-20 oracle?delete誤刪除表數(shù)據(jù)后如何恢復_oracle
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細win安裝深度學習環(huán)境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支