go 中协程同步机制包括:1. 互斥量:同步对共享内存的访问;2. 条件变量:协程在满足条件时等待;3. 信道:协程间通信和同步,通过发送和接收数据;4. 原子变量:并发访问共享变量,无需使用锁。
如何在 Go 中同步多个协程?
在并发编程中,协程是轻量级的线程,可以同时运行以提高性能。然而,有时有必要对多个协程进行同步,以确保它们协调地执行。Go 语言提供了多种机制来实现协程同步。
1. 互斥量(Mutex)
互斥量是一种锁机制,它允许同一时间只有一个协程访问临界区。在 Go 中,可以使用 sync.Mutex 类型创建互斥量。要使用互斥量,请按照以下步骤操作:
- 创建一个 sync.Mutex 变量。
- 在进入临界区之前,使用 Lock() 方法锁定互斥量。
- 离开临界区后,使用 Unlock() 方法解锁互斥量。
import "sync"
var mu sync.Mutex
func main() {
mu.Lock()
// 临界区代码
mu.Unlock()
}
2. 条件变量(Condition Variable)
条件变量允许协程在满足特定条件时等待。在 Go 中,可以使用 sync.Cond 类型创建条件变量。要使用条件变量,请按照以下步骤操作:
- 创建一个 sync.Cond 变量。
- 创建一个 sync.Mutex 变量来保护条件变量。
- 协程可以使用 Wait() 方法等待条件变量被唤醒。
- 协程可以使用 Signal() 方法唤醒等待条件变量的协程。
import "sync"
var cv sync.Cond
var mu sync.Mutex
func main() {
mu.Lock()
cv.Wait(&mu) // 释放锁并等待条件变量被唤醒
mu.Unlock()
}
3. 信道(Channel)
信道是一种 FIFO(先进先出)队列,它允许协程之间通信。协程可以使用 Send() 方法向信道发送数据,并使用 Receive() 方法从信道接收数据。信道可以用于同步协程,因为协程可以在收发数据之前或之后等待。
import "time"
func main() {
ch := make(chan bool)
go func() {
time.Sleep(1 * time.Second)
ch <p><strong>4. 原子变量(Atomic Variable)</strong></p><p>原子变量允许<a style="color:#f60; text-decoration:underline;" href="https://www.php.cn/zt/35877.html" target="_blank">并发访问</a>共享变量,而无需使用锁。在 Go 中,可以使用 sync/atomic 包中的类型创建原子变量。原子变量对于同步简单操作(例如递增计数器)非常有用。</p><pre class="brush:php;toolbar:false">import "sync/atomic"
var counter int64
func main() {
atomic.AddInt64(&counter, 1) // 以原子方式递增计数器
}