go 語言提供了一套并發編程庫和組件，包括 goroutine、channel 和 sync，支持 goroutine 模型、channel 通信和 goroutine 同步。goroutine、channel 和 sync 分別用于創建輕量級線程、在 goroutine 之間傳遞數據和同步 goroutine 執行。實戰中，我們可以利用這些庫和組件并行計算斐波那契數列，通過 goroutine 并行生成數列，channel 傳遞數據，sync.waitgroup 協調 goroutine 執行，高效且安全地實現并發編程。
Go 語言并發編程庫和組件解析
并發編程是現代編程中常見的技術，它允許程序同時執行多個任務，從而提高效率和響應能力。Go 語言提供了一套強大的并發編程庫和組件，使開發者能夠輕松實現各種并發編程模型。
并發編程模型
Go 語言主要支持以下幾種并發編程模型：
goroutine：輕量級線程，用于運行并發任務。
channel：用作 goroutine 之間通信的管道。
sync：用于同步 goroutine 執行的包。
并發編程庫和組件
goroutine
goroutine 是由 Go 語言運行時管理的輕量級線程。它們非常輕巧，允許程序創建大量 goroutine 而不會遇到性能問題。
go func() {
// 并發任務
}()
登錄后復制
channel
channel 是用于 goroutine 之間通信的管道。它們提供一種安全且類型化的方式在 goroutine 之間傳遞數據。
ch := make(chan int)
go func() {
ch <- 42
}()
x := <-ch
登錄后復制
sync
sync 包提供了一組用于同步 goroutine 執行的函數。Mutex、RWMutex 和 WaitGroup 是最常用的同步原語。
var mu sync.Mutex
func foo() {
mu.Lock()
defer mu.Unlock()
// 臨界區
}
登錄后復制
實戰案例
以下是一個使用 goroutine、channel 和 sync 并發計算斐波那契數列的示例：
package main
import (
"fmt"
"sync"
)
func main() {
ch := make(chan int)
var wg sync.WaitGroup
wg.Add(2)
go func() {
defer wg.Done()
ch <- 0
}()
go func() {
defer wg.Done()
ch <- 1
}()
for i := 0; i < 10; i++ {
n1, n2 := <-ch, <-ch
ch <- n1 + n2
}
wg.Wait()
close(ch)
for n := range ch {
fmt.Println(n)
}
}
登錄后復制
在該示例中，我們使用 goroutine 并行生成斐波那契數列，并使用 channel 在 goroutine 之間傳遞數據，使用 sync.WaitGroup 協調 goroutine 的執行。
