一、基本概念
①并發、并行區分
1.概念
- 并發：同一時間段內一個對象執行多個任務,充分利用時間
- 并行：同一時刻,多個對象執行多個任務
2.圖解
類似于超市柜臺結賬,并行是多個柜臺結多個隊列,在計算機中是多核cpu處理多個go語言開啟的線程,并發是一個柜臺結賬多個隊列,在計算機中就是單核cpu處理多個任務,搶奪時間片.
②從用戶態線程,內核態線程闡述go與java并發的優劣
1.用戶態線程、內核態線程差異
- 用戶態：只能受限制的訪問內存,且不允許訪問外圍設備,占用CPU資源可以被其他程序搶走。
- 內核態：CPU可以訪問內存所有數據,包括外圍設備,例如硬盤網卡等,cpu可以將自己從一個程序切換到另一個程序
2.java與go并發差異：
java:
- java沒有規定具體使用什么線程,而是在不同形態的線程上進行切換,會耗費相當的資源
- go是用戶態線程,資源耗費較少，一個線程的棧體默認為1M，并且需要運行在JVM上
go:
- go語言并發通過,goroutine實現，屬于用戶態的線程,可以根據需要創建成千上萬個goroutine，每個goroutine占用內存大小會根據需要動態生成,典型的大小為2kB可以按需求放大到1GB，在go語言中一次可以輕松創建十萬左右的goroutine,并且不依賴運行環境。
②高并發為什么是Go語言強項？
1.歷史背景
Go語言產生較晚,在其產生之前就已經有了多核cpu，所以設計者的理念就是將這門新的語言使用到多核cpu上支持更大數量級的并發
2.自身原因
Go語言多并發底層實現使用的是協程,他占有更少的資源具有更快的執行速度,占用的資源還會根據 任務量進行擴大或者縮小
③Go語言實現高并發底層GMP模型原理解析
1. G：
G是Goroutine的縮寫，在這里就是Goroutine的控制結構，是對Goroutine的抽象。其中包括執行的函數指令及參數；G保存的任務對象；線程上下文切換，現場保護和現場恢復需要的寄存器(SP、IP)等信息。在 Go 語言中使用 runtime.g 結構表示。
2. M:
表示操作系統線程也可以稱為內核線程，由操作系統調度以及管理，調度器最多可以創建 10000 個線程，在 Go 語言中使用 runtime.m 結構表示。（用戶線程與內核線程的映射關系）
3. P:
調度各個goroutine，使他們之間協調運行邏輯處理器，但不代表真正的CPU的數量，真正決定并發程度的是P，初始化的時候一般會去讀取GOMAXPROCS對應的值，如果沒有顯示設置，則會讀取默認值，在Go1.5之后GOMAXPROCS被默認設置可用的核數，而之前則默認為1，在 Go 語言中使用 runtime.p 結構表示。
4.指定cpu線程個數
通過runtime.GOMAXPROCS()，可以指定P的個數,如果沒有指定則默認跑滿整個cpu
二、上代碼學會Go語言并發
①.開啟一個簡單的線程
開啟線程使用go+函數，以下案例要認識到開啟多線程使用函數閉包可能會出現的問題
1.使用匿名函數開啟線程
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
//打印1-1000 for i := 0; i < 1000; i++ { go func() { fmt.Println(i) }() }//這里使用了函數閉包/*打印結果 995 995 995 996 996 999 1000 1000*/ |
2.出問題的原理：
匿名函數進行操作時會將當前環境內的變量進行閉包,由于啟動線程需要一定時間在啟動線程的時候i進行了改變所以打印的時候會有許多值相同
②.動態的關閉線程
1.為什么需要進行動態的關閉線程？
在Go語言中如果不進行動態的關閉線程,那么有可能在子線程沒有執行結束主線程就結束了，那樣的話會有 程序安全隱患,所以主線程不可以直接結束,應作為后盾，直到所有線程都結束了才可以結束。
2.使用waitGroup
waitGroup有三個方法常用：
-
waitGroup.Add（）：使用wait計數器記1次數//將創建的線程數傳進去 -
waitGroup.Done（）：wait計數器減1(放在被開啟線程的函數內) -
waitGroup.Wait（）：阻塞等待wait計數器值為零（放在主線程內）
defer是在函數主體執行完的時候執行的代碼（可理解為延時執行）
代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
package mainimport ( "fmt" "math/rand" "sync" "time")// 定義一個waitGroup結構體變量var wg sync.WaitGroupfunc f(i int) { // 等到函數執行完畢,會將waitGroup內的計數器減一 defer wg.Done() rand.Seed(time.Now().UnixNano()) time.Sleep(time.Duration(rand.Intn(3)) * time.Second) fmt.Println(i)}func main() { for i := 0; i < 100; i++ { // 開啟一個線程就使用waitGroup記一次數 wg.Add(1) go f(i) } // 阻塞等待waitGroup計數器為0 wg.Wait() fmt.Println("hello")} |
總結：
Go語言的高并發奠定了其未來在高級語言中的地位,越來越多的用戶加入互聯網需要一個支持高并發語言的支持,億萬級電商秒殺,億萬級游戲用戶同時在線都離不開這樣的語言,所以Go語言一直被游戲后端、web后端項目開發者青睞。
到此這篇關于Go語言中的并發goroutine底層原理的文章就介紹到這了,更多相關Go語言中的并發goroutine內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/apple_51931783/article/details/122519930
