在Golang中,并發模式主要依賴于goroutines和channels。Goroutines是輕量級的線程,可以在一個操作系統線程上并發執行多個任務。Channels則是用于在goroutines之間傳遞數據的通道。
以下是Golang中常見的并發模式:
go
關鍵字創建一個新的goroutine來執行函數或方法。這樣可以實現并發執行,提高程序的性能。go myFunction()
sync.WaitGroup
來等待一組goroutines完成。這可以確保在繼續執行之前,所有相關的goroutines都已經完成了它們的任務。var wg sync.WaitGroup
wg.Add(2)
go func() {
defer wg.Done()
// Do some work
}()
go func() {
defer wg.Done()
// Do some work
}()
wg.Wait()
sync.Mutex
或sync.RWMutex
來保護共享資源,防止多個goroutines同時訪問。var mu sync.Mutex
var counter int
func increment() {
mu.Lock()
defer mu.Unlock()
counter++
}
ch := make(chan int)
go func() {
ch <- 42
}()
value := <-ch
select
語句在多個channels之間進行選擇。這允許你在多個通道上等待數據,直到其中一個通道接收到數據為止。ch1 := make(chan int)
ch2 := make(chan int)
go func() {
ch1 <- 42
}()
go func() {
ch2 <- 100
}()
select {
case value1 := <-ch1:
fmt.Println("Received from ch1:", value1)
case value2 := <-ch2:
fmt.Println("Received from ch2:", value2)
}
func generateNumbers(ch chan<- int) {
for i := 0; i < 10; i++ {
ch <- i
}
close(ch)
}
func squareNumbers(in <-chan int, out chan<- int) {
for num := range in {
out <- num * num
}
close(out)
}
func main() {
numbers := make(chan int)
squared := make(chan int)
go generateNumbers(numbers)
go squareNumbers(numbers, squared)
for result := range squared {
fmt.Println(result)
}
}
這些并發模式是Golang中常見的并發編程方法。通過使用goroutines和channels,你可以輕松地實現高效、可擴展的并發程序。