一、并發(fā)編程的基本概念

并發(fā)編程是指在一個(gè)程序中同時(shí)運(yùn)行多個(gè)任務(wù)，這些任務(wù)可以獨(dú)立地執(zhí)行，也可以相互協(xié)作。并發(fā)編程可以提高程序的執(zhí)行效率，特別是在處理大量I/O操作或計(jì)算密集型任務(wù)時(shí)。

在Go語(yǔ)言中，并發(fā)編程主要通過(guò)goroutine和channel來(lái)實(shí)現(xiàn)。
Goroutine是Go語(yǔ)言獨(dú)有的并發(fā)執(zhí)行單元，它允許函數(shù)或方法并發(fā)執(zhí)行，而無(wú)需手動(dòng)管理線(xiàn)程。
Channel是Go語(yǔ)言中進(jìn)行g(shù)oroutine間通信和同步的主要機(jī)制。

二、進(jìn)程、線(xiàn)程、協(xié)程

**程序：**指令和數(shù)據(jù)的一個(gè)有序集合。本身沒(méi)有任何含義，是一個(gè)靜態(tài)的概念。

進(jìn)程：QQ.exe 微信 … 一個(gè)個(gè)的程序、執(zhí)行起來(lái)之后，開(kāi)啟一個(gè)進(jìn)程。執(zhí)行程序的一次執(zhí)行過(guò)程，它是動(dòng)態(tài)的概念。進(jìn)程是系統(tǒng)資源分配的單位。

**線(xiàn)程：**一個(gè)進(jìn)程中可以有多個(gè)線(xiàn)程，并行的，一個(gè)進(jìn)程之中，至少要有一個(gè)線(xiàn)程。main 主線(xiàn)程

• 線(xiàn)程是CPU調(diào)度和執(zhí)行的單位。
• 一個(gè)線(xiàn)程，直接執(zhí)行就可以了
• 多個(gè)線(xiàn)程：CPU如何調(diào)度執(zhí)行。 一個(gè)CPU、也是可以跑多個(gè)線(xiàn)程的。

并行和并發(fā)

• 并發(fā):一個(gè)cpu同一時(shí)間不停執(zhí)行多個(gè)程序
• 并行:多個(gè)cpu同一時(shí)間不停執(zhí)行多個(gè)程序

在代碼級(jí)別中的所謂多線(xiàn)程并發(fā)處理問(wèn)題。模擬出來(lái)的。

• 真正的多線(xiàn)程是指的擁有多個(gè)CPU、多核
• 如果是模擬出來(lái)的多線(xiàn)程、即在一個(gè)CPU的情況下，在同一個(gè)時(shí)間點(diǎn)，只能執(zhí)行一個(gè)線(xiàn)程的代碼。
• 因?yàn)閳?zhí)行的速度很快，所以就有了同時(shí)在執(zhí)行的一種錯(cuò)覺(jué)。

并行真的就最快嗎？

• 并行運(yùn)行的組件，考慮到多個(gè)線(xiàn)程之間的通信問(wèn)題，這種跨CPU通信問(wèn)題是開(kāi)銷(xiāo)比較高的，并行并不一定快。

進(jìn)程

進(jìn)程是一個(gè)程序在一個(gè)數(shù)據(jù)集中的一次動(dòng)態(tài)執(zhí)行過(guò)程，可以簡(jiǎn)單理解為“正在執(zhí)行的程序"，它是CPU資源分配和調(diào)度的獨(dú)立單位。

進(jìn)程一般由程序、數(shù)據(jù)集、進(jìn)程控制塊三部分組成。我們編寫(xiě)的程序用來(lái)描述進(jìn)程要完成哪些功能以及如何完成;

數(shù)據(jù)集則是程序在執(zhí)行過(guò)程中所需要使用的資源;進(jìn)程控制塊用來(lái)記錄進(jìn)程的外部特征，描述進(jìn)程的執(zhí)行變化過(guò)程，系統(tǒng)可以利用它來(lái)控制和管理進(jìn)程，它是系統(tǒng)感知進(jìn)程存在的唯一標(biāo)志。 進(jìn)程的局限是創(chuàng)建、撤銷(xiāo)和切換的開(kāi)銷(xiāo)比較大。

線(xiàn)程 :

線(xiàn)程是在進(jìn)程之后發(fā)展出來(lái)的概念。線(xiàn)程也叫輕量級(jí)進(jìn)程，它是一個(gè)基本的CPU執(zhí)行單元，也是程序執(zhí)行過(guò)程中的最小單元，由線(xiàn)程ID、 程序計(jì)數(shù)器、寄存器集合和堆棧共同組成。一個(gè)進(jìn)程可以包含多個(gè)線(xiàn)程。

線(xiàn)程的優(yōu)點(diǎn)是減小了程序并發(fā)執(zhí)行時(shí)的開(kāi)銷(xiāo)，提高了操作系統(tǒng)的并發(fā)性能，**缺點(diǎn)是線(xiàn)程沒(méi)有自己的系統(tǒng)資源，同一進(jìn)程的各線(xiàn)程可以共享進(jìn)程所擁有的系統(tǒng)資源，如果把進(jìn)程比作一個(gè)車(chē)間，那么線(xiàn)程就好比是車(chē)間里面的工人。**不過(guò)對(duì)于某些獨(dú)占性資源存在鎖機(jī)制，處理不當(dāng)可能會(huì)產(chǎn)生”死鎖"。

協(xié)程Goroutine

協(xié)程是一種用戶(hù)態(tài)的輕量級(jí)線(xiàn)程，又稱(chēng)微線(xiàn)程，英文名Coroutine,協(xié)程的調(diào)度完全由用戶(hù)控制。人們通常將協(xié)程和子程序(函數(shù))比較著理解。

就好比是啟動(dòng)了一個(gè)函數(shù)，單次執(zhí)行完畢它。不影響我們main線(xiàn)程的執(zhí)行。

子程序調(diào)用總是一個(gè)入口，一次返回，一旦退出即完成了子程序的執(zhí)行。

與傳統(tǒng)的系統(tǒng)級(jí)線(xiàn)程和進(jìn)程相比，協(xié)程的最大優(yōu)勢(shì)在于其"輕量級(jí)”，可以輕松創(chuàng)建上百萬(wàn)個(gè)而不會(huì)導(dǎo)致系統(tǒng)資源衰竭，而線(xiàn)程和進(jìn)程通常最多也不能超過(guò)1萬(wàn)的。這也是協(xié)程也叫輕量級(jí)線(xiàn)程的原因。

補(bǔ)充點(diǎn)：Go語(yǔ)言流行的主要一個(gè)原因，高并發(fā)的問(wèn)題。高效！

Go語(yǔ)言對(duì)于并發(fā)的實(shí)現(xiàn)是靠協(xié)程，Goroutine

三、Goroutine

Go中使用Goroutine來(lái)實(shí)現(xiàn)并發(fā)concurrently

**Goroutine是Go語(yǔ)言特有的名詞。**區(qū)別于進(jìn)程Process,線(xiàn)程Thread, 協(xié)程Goroutine, 因?yàn)镚o語(yǔ)言的創(chuàng)造者們覺(jué)得和他們是有所區(qū)別的，所以專(zhuān)門(mén)創(chuàng)造了Goroutine

Goroutine是與其他函數(shù)或方法同時(shí)運(yùn)行的函數(shù)或方法。Goroutines可以被認(rèn)為是輕量級(jí)的線(xiàn)程。與線(xiàn)程相比，創(chuàng)建Goroutine的成本很小，它就是一段代碼，一個(gè)函數(shù)入口。以及在堆上為其分配的一個(gè)堆棧(初始大小為4K,會(huì)隨著程序的執(zhí)行自動(dòng)增長(zhǎng)刪除)。因此它非常廉價(jià)，Go應(yīng)用程序可以輕松并發(fā)運(yùn)行數(shù)千個(gè)Goroutines

在go語(yǔ)言中使用 goroutine，在調(diào)用函數(shù)或者方法前面加上 go 關(guān)鍵字即可。

普通方法調(diào)用 對(duì)比 多線(xiàn)程
**普通方法調(diào)用：**串行

main(){ // 串行執(zhí)行 1/2/3
    test1()
    test2()
    test3()
}

多線(xiàn)程

main(){ // 4個(gè)線(xiàn)程同時(shí)執(zhí)行：main test1  test2 test3 、交替的快速執(zhí)行。
   go test1()
   go test2()
   go test3()
}

四、Goroutine的創(chuàng)建和使用

Goroutine是由Go的運(yùn)行時(shí)調(diào)度和管理的輕量級(jí)線(xiàn)程。每個(gè)goroutine都有自己獨(dú)立的?？臻g，并且由Go的運(yùn)行時(shí)環(huán)境進(jìn)行調(diào)度。
與線(xiàn)程不同，goroutine的創(chuàng)建和切換成本更低，因?yàn)樗皇呛瘮?shù)入口和堆棧的封裝，不需要像線(xiàn)程那樣進(jìn)行復(fù)雜的上下文切換。

1. 創(chuàng)建Goroutine

在Go語(yǔ)言中，使用go關(guān)鍵字來(lái)創(chuàng)建一個(gè)新的goroutine。例如：

package main

import (
    "fmt"
    "time"
)

func main() {
    //使用go關(guān)鍵字來(lái)創(chuàng)建goroutine協(xié)程
    go Hello()
    time.Sleep(1 * time.Second) // 等待一秒鐘，確保Hello函數(shù)有足夠的時(shí)間執(zhí)行。如果不加等待，main函數(shù)如果結(jié)束了，所有的 goroutine也會(huì)瞬間銷(xiāo)毀
}

func Hello() {
    fmt.Println("hello world")
}

2. Goroutine的規(guī)則

1、當(dāng)新的Goroutine開(kāi)始時(shí)， Goroutine調(diào)用立即返回。與函數(shù)不同，go不等待Goroutine執(zhí)行結(jié)束

2、當(dāng)Goroutine調(diào)用，并且Goroutine的任何返回值被忽略之后，go立即執(zhí)行到下一行代碼

3、main的Goroutine應(yīng)該為其他的Goroutines執(zhí)行。如果main的Goroutine終止了，程序?qū)⒈唤K止，而其他Goroutine將不會(huì)運(yùn)行

五、Goroutine的生命周期和調(diào)度

Go程序在一個(gè)主Goroutine中啟動(dòng)，這個(gè)主Goroutine封裝了main函數(shù)。主Goroutine會(huì)進(jìn)行一系列的初始化工作，包括設(shè)置每個(gè)goroutine能申請(qǐng)的?？臻g的最大尺寸、啟動(dòng)垃圾回收Goroutine等。

當(dāng)使用go關(guān)鍵字創(chuàng)建一個(gè)新的Goroutine時(shí)，Go的運(yùn)行時(shí)會(huì)創(chuàng)建一個(gè)新的輕量級(jí)線(xiàn)程，并分配一個(gè)Goroutine棧，然后將該Goroutine添加到調(diào)度器中。
調(diào)度器會(huì)根據(jù)調(diào)度算法選擇一個(gè)可用的Goroutine運(yùn)行。如果當(dāng)前沒(méi)有可用的Goroutine，程序可能會(huì)進(jìn)入休眠狀態(tài)。

Goroutine在調(diào)用某些會(huì)引起阻塞的函數(shù)時(shí)，會(huì)被暫停，直到函數(shù)返回結(jié)果。
這些函數(shù)包括I/O操作、網(wǎng)絡(luò)請(qǐng)求、系統(tǒng)調(diào)用、鎖等。
當(dāng)Goroutine阻塞時(shí)，調(diào)度器會(huì)將它放回到隊(duì)列中，直到它再次準(zhǔn)備好運(yùn)行。

主Goroutine - mian
封裝main函數(shù)的goroutine稱(chēng)為主goroutine。
主goroutine所做的事情并不是執(zhí)行main函數(shù)那么簡(jiǎn)單。它首先要做的是:設(shè)定每一個(gè)goroutine所能申請(qǐng)的棧空間的最大尺寸。
在32位的計(jì)算機(jī)系統(tǒng)中此最大尺寸為250MB,而在64位的計(jì)算機(jī)系統(tǒng)中此尺寸為1GB。
如果有某個(gè)goroutine的棧空間尺寸大于這個(gè)限制，那么運(yùn)行時(shí)系統(tǒng)就會(huì)引發(fā)一個(gè)棧溢出(stack overflow)的運(yùn)行時(shí)恐慌。隨后，這個(gè)go程序的運(yùn)行也會(huì)終止。

此后，主goroutine會(huì) 進(jìn)行一系列的初始化工作，涉及的工作內(nèi)容大致如下:

1、創(chuàng)建一個(gè)特殊的defer語(yǔ)句，用于在主goroutine退出時(shí)做必要的善后處理。因?yàn)橹鱣oroutine也可能非正常的結(jié)束

2、啟動(dòng)專(zhuān)用于在后臺(tái)清掃內(nèi)存垃圾的goroutine,并設(shè)置GC可用的標(biāo)識(shí).

3、執(zhí)行main包中所引用包下的init函數(shù)

4、執(zhí)行main函數(shù)

執(zhí)行完main函數(shù)后，它還會(huì)檢查主goroutine是否引發(fā)了運(yùn)行時(shí)恐慌，并進(jìn)行必要的處理。

程序運(yùn)行完畢后，主goroutine會(huì)結(jié)束自己以及當(dāng)前進(jìn)程的運(yùn)行。

六、使用runtime包管理Goroutine

Go語(yǔ)言的runtime包提供了與Go運(yùn)行時(shí)環(huán)境交互的各種功能，包括垃圾回收、并發(fā)控制、程序退出、堆棧管理等。以下是一些常用的runtime包函數(shù)：

• runtime.GOMAXPROCS：設(shè)置最大可運(yùn)行的操作系統(tǒng)線(xiàn)程數(shù)。
• runtime.NumCPU：返回機(jī)器的CPU核心數(shù)。
• runtime.NumGoroutine：返回當(dāng)前運(yùn)行的Goroutine數(shù)量。
• runtime.Gosched：讓出CPU時(shí)間片，使得其他Goroutine可以運(yùn)行。
• runtime.Goexit：退出當(dāng)前的Goroutine。
• runtime.KeepAlive：確保某個(gè)Goroutine不會(huì)被垃圾回收。
• runtime.SetFinalizer：為對(duì)象設(shè)置終結(jié)器，當(dāng)垃圾回收器準(zhǔn)備回收該對(duì)象時(shí)，會(huì)調(diào)用該終結(jié)器。
• runtime.GC：強(qiáng)制運(yùn)行垃圾回收器。
• runtime.GOOS: 獲取操作系統(tǒng)名稱(chēng)

這些函數(shù)可以幫助我們更好地管理Goroutine和并發(fā)編程。
例如，可以使用runtime.GOMAXPROCS來(lái)設(shè)置最大可運(yùn)行的操作系統(tǒng)線(xiàn)程數(shù)，從而控制并發(fā)度。
可以使用runtime.NumGoroutine來(lái)監(jiān)控當(dāng)前運(yùn)行的Goroutine數(shù)量，以便進(jìn)行性能調(diào)優(yōu)。

獲取系統(tǒng)的信息runtime

package main

import (
    "fmt"
    "runtime"
)

// 獲取系統(tǒng)的信息runtime
func main() {
    // 獲取goRoot目錄 : 找到指定目錄，存放一些項(xiàng)目信息。
    fmt.Println("GoRoot Path:", runtime.GOROOT())
    // 獲取操作系統(tǒng)  windows ，可以根據(jù)操作系統(tǒng)類(lèi)型判斷盤(pán)符分隔符。 “\\”  “/”
    fmt.Println("System:", runtime.GOOS)
    // 獲取cpu數(shù)量 12， 可以嘗試做一些系統(tǒng)優(yōu)化，開(kāi)啟更大的?？臻g。
    fmt.Println("Cpu num:", runtime.NumCPU())
}

并發(fā)控制

package main

import (
    "fmt"
    "runtime"
)

// 控制并發(fā)順序
func main() {
    // goroutine是競(jìng)爭(zhēng)cpu的  ，調(diào)度
    go func() {
        for i := 0; i < 5; i++ {
            fmt.Println("goroutine", i)
        }
    }()

    for i := 0; i < 5; i++ {
        // gosched:禮讓, 讓出時(shí)間片，讓其他的 goroutine 先執(zhí)行
        // cpu是隨機(jī)，相對(duì)來(lái)說(shuō)，可以讓一下，但是不一定能夠成功
        // schedule
        runtime.Gosched()
        fmt.Println("main-", i)
    }
}

正常情況下，main主函數(shù)里面的協(xié)程一般是先于go func()執(zhí)行的，但是我們?cè)趍ain函數(shù)里面加上了runtime.Gosched()，這樣main函數(shù)里面的代碼執(zhí)行就讓出CPU時(shí)間片，讓其他Goroutine先執(zhí)行

Goroutine的終止和清理

使用runtime.Goexit()終止Goroutine
runtime.Goexit()函數(shù)用于終止當(dāng)前Goroutine的執(zhí)行。當(dāng)調(diào)用Goexit()時(shí)，當(dāng)前Goroutine會(huì)立即停止執(zhí)行，并把控制權(quán)交還給調(diào)度器。
這意味著當(dāng)前Goroutine不會(huì)繼續(xù)執(zhí)行后續(xù)的代碼，也不會(huì)返回到調(diào)用它的地方。同時(shí)，其他仍在運(yùn)行的Goroutine將繼續(xù)執(zhí)行。例如：

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() {
    go func() {
        defer fmt.Println("A.defer")

        func() {
            defer fmt.Println("B.defer")
                        //return // 只是終止了函數(shù)

            //這里設(shè)置，終止當(dāng)前的 goroutine，該Goroutine中下面的代碼不再執(zhí)行
            runtime.Goexit()
            defer fmt.Println("C.defer")
            fmt.Println("B")
        }()

        fmt.Println("A")
    }()

    time.Sleep(1 * time.Second)
}

七、多線(xiàn)程會(huì)遇到的問(wèn)題

1. 臨界資源的安全問(wèn)題

臨界資源：指并發(fā)環(huán)境中多個(gè)進(jìn)程、線(xiàn)程、協(xié)程共享的資源

在并發(fā)編程中對(duì)臨界資源的處理不當(dāng)，往往會(huì)導(dǎo)致數(shù)據(jù)不一致的問(wèn)題。

package main

import (
    "fmt"
    "time"
)

func main() {
    // 此時(shí)的a就是臨界資源：多個(gè)協(xié)程共享的變量，會(huì)導(dǎo)致程序結(jié)果未知
    a := 1

    go func() {
        a = 2
        fmt.Println("goroutine a:", a)
    }()

    a = 3
    time.Sleep(3 * time.Second)
    fmt.Println("main a:", a)
}

2. 經(jīng)典案例：售票問(wèn)題

并發(fā)本身并不復(fù)雜，但是因?yàn)橛辛速Y源競(jìng)爭(zhēng)的問(wèn)題，就使得我們開(kāi)發(fā)出好的并發(fā)程序變得復(fù)雜起來(lái)，因?yàn)闀?huì)引起很多莫名其妙的問(wèn)題。

如果多個(gè)goroutine在訪(fǎng)問(wèn)同一個(gè)數(shù)據(jù)資源的時(shí)候，其中一個(gè)線(xiàn)程修改了數(shù)據(jù)，那么這個(gè)數(shù)值就被修改了，對(duì)于其他的goroutine來(lái)講，這個(gè)數(shù)值可能是不對(duì)的。

package main

import (
    "fmt"
    "time"
)

// 定義全局變量 票庫(kù)存為10張
var ticket int = 10

func main() {
    // 單線(xiàn)程不存在問(wèn)題，多線(xiàn)程資源爭(zhēng)搶就出現(xiàn)了問(wèn)題
    //多人搶票
    go saleTickets("張三")
    go saleTickets("李四")
    go saleTickets("王五")
    go saleTickets("趙六")

    time.Sleep(time.Second * 5)
}

// 售票函數(shù)
func saleTickets(name string) {
    for {
        if ticket > 0 {
            time.Sleep(time.Millisecond * 1)
            fmt.Println(name, "剩余票的數(shù)量為：", ticket)
            //每賣(mài)出一張票，票的數(shù)量減一
            ticket--
        } else {
            fmt.Println("票已售完")
            break
        }
    }
}

多線(xiàn)程都在操作數(shù)據(jù)，出現(xiàn)了負(fù)數(shù)這種不合理的結(jié)果

發(fā)現(xiàn)結(jié)果和預(yù)想的不同，多線(xiàn)程加入之后，原先單線(xiàn)程的邏輯出現(xiàn)了問(wèn)題。

以上就是詳解Go語(yǔ)言中如何通過(guò)Goroutine實(shí)現(xiàn)高并發(fā)的詳細(xì)內(nèi)容，更多關(guān)于Go Goroutine實(shí)現(xiàn)高并發(fā)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論