go 中的同步机制包括:通道:用于在 goroutine 之间安全地传递数据,采用阻塞式发送和接收操作。互斥锁:确保同一时间只有一个 goroutine 可以访问共享资源。等待组:跟踪正在等待完成的 goroutine 数量,主 goroutine 可通过该机制等待所有 goroutine 完成再继续执行。
Go 中函数和 Goroutine 的同步机制
在 Go 中,函数和 Goroutine 是并发的执行单元。为了确保它们之间的协调和数据完整性,需要使用同步机制。本文将介绍 Go 中常用的同步机制,并提供实战案例。
通道 (Channel)
通道是一种用于在 Goroutine 之间安全地传递数据的缓冲区。通道的发送操作(ch )和接收操作(<code>v := )都是阻塞的。这意味着发送方只有在通道中有可用的空间时才会发送数据,而接收方只有在通道中有可用数据时才会接收数据。
实战案例:使用通道在多个 Goroutine 之间传递数据
package main import "fmt" func main() { // 创建一个带有缓冲区的通道(可以存储最多 10 个值) ch := make(chan int, 10) // 启动 5 个 Goroutine 向通道发送数据 for i := 0; i < 5; i++ { go func(i int) { ch <- i }(i) } // 从通道接收数据并打印结果 for i := 0; i < 5; i++ { fmt.Println(<-ch) } }