Go語言中并發goroutine底層原理的示例分析

小編給大家分享一下Go語言中并發goroutine底層原理的示例分析，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

一、基本概念

①并發、并行區分

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-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是在函數主體執行完的時候執行的代碼（可理解為延時執行）

代碼如下：

package main

import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)
// 定義一個waitGroup結構體變量
var wg sync.WaitGroup

func 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語言中并發goroutine底層原理的示例分析”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！