在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,你可以轻松地实现高效、可扩展的并发程序。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
相关推荐:Golang中的并发原语有哪些