使用WaitGroup 和互斥體實現並發Goroutines 的互斥
Go 中一次只有一個Goroutine 的情況下實現並發互的斥可以執行某些程式碼，我們可以利用WaitGroup 和互斥體的組合。
WaitGroup 是一個同步原語，它允許我們等待一組 goroutine 完成執行後再繼續。另一方面，互斥鎖提供了互斥鎖機制，確保程式碼的關鍵部分不會同時被多個 goroutine 執行。
考慮以下範例程式碼：
<code class="go">package main
import (
"fmt"
"rand"
"sync"
)
var (
mutex1, mutex2, mutex3 sync.Mutex
wg sync.WaitGroup
)
func Routine1() {
mutex1.Lock()
defer mutex1.Unlock() // Ensure mutex is always unlocked before returning
// do something
// Sending and printing events should be mutually exclusive
for i := 0; i < 200; i++ {
mutex2.Lock()
defer mutex2.Unlock()
mutex3.Lock()
defer mutex3.Unlock()
fmt.Println("value of z")
}
// do something
}
func Routine2() {
mutex2.Lock()
defer mutex2.Unlock()
// do something
// Sending and printing events should be mutually exclusive
for i := 0; i < 200; i++ {
mutex1.Lock()
defer mutex1.Unlock()
mutex3.Lock()
defer mutex3.Unlock()
fmt.Println("value of z")
}
// do something
}
func Routine3() {
mutex3.Lock()
defer mutex3.Unlock()
// do something
// Sending and printing events should be mutually exclusive
for i := 0; i < 200; i++ {
mutex1.Lock()
defer mutex1.Unlock()
mutex2.Lock()
defer mutex2.Unlock()
fmt.Println("value of z")
}
// do something
}
func main() {
wg.Add(3)
go Routine1()
go Routine2()
Routine3()
wg.Wait() // Wait for all goroutines to complete
}</code>在此程式碼中，我們有三個獨立的 goroutine（Routine1、Routine2 和 Routine3），它們都同時執行某些操作。然而，我們希望確保程式碼的某些部分（發送和列印事件）的執行不受其他 goroutine 的干擾。
我們透過利用互斥體來實現這一點。我們定義三個互斥體（互斥體 1、互斥體 2 和互斥體 3），並在執行臨界區之前取得對應互斥體的鎖。當一個互斥鎖被一個 goroutine 鎖定時，其他嘗試取得相同鎖的 goroutine 將被阻塞，直到該鎖變得可用。
透過鎖定和解鎖適當的互斥鎖，我們確保只有一個 goroutine 可以執行臨界區在任何給定時間。這可以防止這些程式碼段同時執行，並保持 goroutine 之間的互斥。
最後，我們使用 WaitGroup 來確保 main 函數在所有三個 goroutine 完成執行之前不會退出。這使我們能夠同步 goroutine 並控製程式的流程。
以上是Go中如何使用WaitGroups和Mutexes來實現並發goroutine之間的互斥？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
