本文探討在Linux環境下，如何利用go語言高效地進行并發控制。Go語言提供的goroutine、channel和sync包是實現并發控制的關鍵工具。
1. Goroutine：輕量級并發單元
Goroutine是Go語言的并發執行單元，其輕量級特性允許在單一程序中同時運行大量goroutine。創建goroutine只需在函數調用前添加go關鍵字：
package main import ( "fmt" "time" ) func printNumbers() { for i := 1; i <= 5; i++ { fmt.Printf("Number: %d ", i) time.Sleep(1 * time.Second) } } func main() { go printNumbers() time.Sleep(6 * time.Second) }
2. channel：goroutine間安全通信
立即學習“go語言免費學習筆記（深入）”；
Channel是Go語言中用于goroutine之間安全地傳遞數據的通道。使用make函數創建channel，確保數據在并發訪問下的一致性：
package main import ( "fmt" "time" ) func printNumbers(numbers chan int) { for num := range numbers { fmt.Printf("Number: %d ", num) time.Sleep(1 * time.Second) } } func main() { numbers := make(chan int, 5) go printNumbers(numbers) for i := 1; i <= 5; i++ { numbers <- i } close(numbers) }
3. sync包：同步工具集
sync包提供多種同步工具，例如WaitGroup、Mutex和Cond，用于協調goroutine的執行。
package main import ( "fmt" "sync" "time" ) func printNumbers(wg *sync.WaitGroup) { defer wg.Done() for i := 1; i <= 5; i++ { fmt.Printf("Number: %d ", i) time.Sleep(1 * time.Second) } } func main() { var wg sync.WaitGroup wg.Add(1) go printNumbers(&wg) wg.Wait() }
- Mutex：互斥鎖，保護共享資源 Mutex的Lock和Unlock方法確保同一時間只有一個goroutine可以訪問共享資源，防止數據競爭：
package main import ( "fmt" "sync" "time" ) var counter int var mutex sync.Mutex func incrementCounter() { mutex.Lock() defer mutex.Unlock() counter++ fmt.Printf("Counter: %d ", counter) time.Sleep(1 * time.Second) } func main() { wg := sync.WaitGroup{} for i := 0; i < 5; i++ { wg.Add(1) go func() { defer wg.Done() incrementCounter() }() } wg.Wait() }
通過靈活運用goroutine、channel和sync包提供的工具，可以有效地管理Go程序中的并發，構建高性能、可靠的應用。 記住根據實際需求選擇合適的并發控制方法，并謹慎處理共享資源的訪問，以避免潛在的并發問題。
