Go言語のMutexとRwMutexの違いと使い分けについて解説

package main
import (
	"fmt"
	"sync"
)
func main() {
	// Mutexの変数を宣言
	var mu sync.Mutex
	counter := 0
	// 5回のループでカウンターをインクリメントするサンプル
	for i := 0; i < 5; i++ {
		mu.Lock() // ロックを取得して排他制御開始
		counter++ // カウンターを更新
		fmt.Println("現在のカウンター:", counter)
		mu.Unlock() // ロックを解放して排他制御終了
	}
}

現在のカウンター: 1
現在のカウンター: 2
現在のカウンター: 3
現在のカウンター: 4
現在のカウンター: 5

package main
import (
	"fmt"
	"sync"
)
func main() {
	// RwMutexの変数を宣言
	var rwMu sync.RWMutex
	sharedData := 100
	var wg sync.WaitGroup
	// 読み取り処理を実行するゴルーチン
	wg.Add(1)
	go func() {
		defer wg.Done()
		rwMu.RLock() // 読み取りロックを取得
		fmt.Println("読み取り処理: sharedData =", sharedData)
		rwMu.RUnlock() // 読み取りロックを解放
	}()
	// 書き込み処理を実行するゴルーチン
	wg.Add(1)
	go func() {
		defer wg.Done()
		rwMu.Lock() // 書き込みロックを取得
		sharedData = 200 // sharedDataを書き換え
		fmt.Println("書き込み処理: sharedDataを変更")
		rwMu.Unlock() // 書き込みロックを解放
	}()
	wg.Wait()
	fmt.Println("最終的なsharedData =", sharedData)
}

読み取り処理: sharedData = 100
書き込み処理: sharedDataを変更
最終的なsharedData = 200

package main
import (
	"fmt"
	"sync"
)
func main() {
	// Mutex変数の宣言
	var mu sync.Mutex
	counter := 0
	// 5つの更新処理を順次実行
	for i := 0; i < 5; i++ {
		mu.Lock()            // ロックを取得して排他制御開始
		counter++            // カウンターのインクリメント
		fmt.Println("カウンター更新:", counter)
		mu.Unlock()          // ロックを解放して排他制御終了
	}
}

カウンター更新: 1
カウンター更新: 2
カウンター更新: 3
カウンター更新: 4
カウンター更新: 5

package main
import (
	"fmt"
	"sync"
)
func main() {
	// RwMutex変数の宣言
	var rwMu sync.RWMutex
	sharedData := 50
	var wg sync.WaitGroup
	// 読み取り処理を実行するゴルーチン
	wg.Add(1)
	go func() {
		defer wg.Done()
		rwMu.RLock() // 読み取りロックを取得
		fmt.Println("読み取り処理: sharedData =", sharedData)
		rwMu.RUnlock() // 読み取りロックを解放
	}()
	// 書き込み処理を実行するゴルーチン
	wg.Add(1)
	go func() {
		defer wg.Done()
		rwMu.Lock() // 書き込みロックを取得
		sharedData = 75 // 値を変更
		fmt.Println("書き込み処理: sharedDataを更新")
		rwMu.Unlock() // 書き込みロックを解放
	}()
	wg.Wait()
	fmt.Println("最終結果: sharedData =", sharedData)
}

読み取り処理: sharedData = 50
書き込み処理: sharedDataを更新
最終結果: sharedData = 75