首頁 > 後端開發 > Golang > golang 平行寫法是什麼

golang 平行寫法是什麼

PHPz
發布: 2023-04-11 10:14:53
原創
593 人瀏覽過

在現代軟體開發中,有效利用電腦硬體資源是至關重要的。平行程式設計就是一種能夠最大化利用多核心CPU的程式設計方式。與其他程式語言相比,Go語言(也叫Golang)內建了支援並發程式設計的工具和機制,因此在平行程式設計領域得到了廣泛的應用和認可。

本文將介紹一些在Golang中實作並行程式設計的方法和技術,以及它們的適用場景和注意事項。

一、Goroutine和Channel

Goroutine是Golang從其他程式語言中藉鏡而來的一種平行程式設計模型。它被稱為輕量級線程,可以更有效率地利用電腦的多核心處理能力。每個Goroutine都由Golang的執行階段系統自動管理,開發者只需要透過執行go關鍵字來建立Goroutine。

例如:

func main() {
    go func() {
        fmt.Println("Hello, Goroutine!")
    }()
    fmt.Println("Hello, World!")
}
登入後複製

在這段程式碼中,我們建立了一個匿名函數並用go關鍵字轉換成Goroutine。程式會同時輸出"Hello, World!"和"Hello, Goroutine!"。

Channel是Golang中用於Goroutine之間通訊的機制。 Channel可以用來傳輸任意類型的數據,因此可以在不同Goroutine之間傳遞資料和控制資訊。

例如:

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("worker", id, "started  job", j)
        time.Sleep(time.Second)
        fmt.Println("worker", id, "finished job", j)
        results <- j * 2
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }
    for j := 1; j <= 9; j++ {
        jobs <- j
    }
    close(jobs)
    for a := 1; a <= 9; a++ {
        <-results
    }
}
登入後複製

在這段程式碼中,我們定義了一個worker函數,它接收兩個Channel:一個用於接收任務,另一個用於將任務結果傳回。我們創建了3個Goroutine,每個Goroutine都會從jobs Channel中取得任務,並將處理結果寫入到results Channel中。最後,我們使用for迴圈將9個任務傳送到jobs Channel中,並將results Channel的值輸出到標準輸出。注意,我們需要在for迴圈後關閉jobs Channel,以使worker函數終止。

二、Sync套件

在Golang中,Sync套件提供了一些並行程式設計所需的同步工具,例如:

· WaitGroup:等待一組Goroutine完成任務;
· Mutex:實現對共享資料的互斥存取;
· Cond:條件變量,在多個Goroutine之間進行通訊和同步。

這裡我們將展示一個使用WaitGroup的範例:

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting\n", id)

    time.Sleep(time.Second)
    fmt.Printf("Worker %d done\n", id)
}

func main() {
    var wg sync.WaitGroup

    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }

    wg.Wait()
}
登入後複製

在這個範例中,我們定義了一個worker函數,它接收WaitGroup指標作為參數。在函數工作完成後,我們呼叫WaitGroup的Done方法來通知其所屬的Goroutine任務已經完成。在主函數中,我們為每個worker函數建立一個Goroutine,並使用WaitGroup的Add方法來告訴WaitGroup這裡有一組Goroutine正在執行。最後,我們呼叫Wait方法來等待所有Goroutine完成任務。

三、設定GOMAXPROCS

在Golang中,GOMAXPROCS是一個數字,表示應該同時執行多少個Goroutine。如果這個數字設定得太小,程式的並行性會受到限制。如果設定太大,會浪費電腦的資源。因此,我們需要根據電腦的處理器核心數來設定GOMAXPROCS的值,以避免過度或不充分利用電腦的資源。

預設情況下,Golang的GOMAXPROCS是等於處理器核心數的,可以在程式碼中使用runtime套件修改它:

import "runtime"

//...

func main() {
    numCPU := runtime.NumCPU()
    runtime.GOMAXPROCS(numCPU)

    //...
}
登入後複製

這裡,我們使用runtime套件取得了處理器核心數,然後設定GOMAXPROCS的值等於核心數。

總結

本文介紹了Golang中並發程式設計的幾種方法和技術,包括Goroutine和Channel、Sync套件、以及設定GOMAXPROCS。並發程式設計雖然能夠提高程式的效能和效率,但也會帶來一些風險和挑戰。因此,在進行並行程式設計時,我們需要根據實際情況選擇合適的方案,並注意控制好並行性的程度,避免不必要的錯誤和資源浪費。

以上是golang 平行寫法是什麼的詳細內容。更多資訊請關注PHP中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板