Golang中的并发模式有哪些

在Golang中，并发模式主要依赖于goroutines和channels。Goroutines是轻量级的线程，可以在一个操作系统线程上并发执行多个任务。Channels则是用于在goroutines之间传递数据的通道。

以下是Golang中常见的并发模式：

1. 并发执行：使用go关键字创建一个新的goroutine来执行函数或方法。这样可以实现并发执行，提高程序的性能。

go myFunction() 

2. 同步：使用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() 

3. 互斥：使用sync.Mutex或sync.RWMutex来保护共享资源，防止多个goroutines同时访问。

var mu sync.Mutex var counter int  func increment() {     mu.Lock()     defer mu.Unlock()     counter++ } 

4. 通信：使用channels在goroutines之间传递数据。这是一种非常强大的同步机制，可以确保数据在不同的goroutines之间安全地传递。

ch := make(chan int)  go func() {     ch <- 42 }()  value := <-ch 

5. 选择：使用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) } 

6. 管道：使用channels创建管道，将一个goroutine的输出作为另一个goroutine的输入。这可以实现高效的数据处理流水线。

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，你可以轻松地实现高效、可扩展的并发程序。