Go言語の並行処理を完全攻略！MutexとChannelを視覚的に学ぶ

package main
import (
	"sync"
	"time"
)
func main() {
	println("直列処理による実行")
	for i := 1; i <= 5; i++ {
		println(i)
		time.Sleep(1 * time.Second)
	}
	println("Goルーチンによる実行")
	
	// Waiting Groupの定義
	var wg sync.WaitGroup
	// 1から5までの数値をゴルーチンで出力
	for i := 1; i <= 5; i++ {
		wg.Add(1) // Waiting Groupのカウンタを増やす
		// ゴルーチンとして処理を定義
		go func(i int) {
			defer wg.Done() // ルーチンの最後にWgのカウンタを１つ取り除く
			println(i)
			time.Sleep(1 * time.Second)
		}(i)
	}
	wg.Wait() // Waiting Groupのカウンタが0になるまで待機
}

直列処理による実行
2025/01/08 07:55:59 1
2025/01/08 07:56:00 2
2025/01/08 07:56:01 3
2025/01/08 07:56:02 4
2025/01/08 07:56:03 5
Goルーチンによる実行
2025/01/08 07:56:04 2
2025/01/08 07:56:04 5
2025/01/08 07:56:04 4
2025/01/08 07:56:04 3
2025/01/08 07:56:04 1

.vscode/tasks.json
code/git/channel.go
code/git/mutex.go
code/git/no_mutex.go
code/go.sum
code/util/encoding.go
code/util/map.go
docs/dummy.txt

{
  ".vscode": {
    "tasks.json": "tasks.json"
  },
  "code": {
    "git": {
      "channel.go": "channel.go",
      "mutex.go": "mutex.go",
      "no_mutex.go": "no_mutex.go"
    },
    "go.sum": "go.sum",
    "util": {
      "encoding.go": "encoding.go",
      "map.go": "map.go"
    }
  },
  "docs": {
    "dummy.txt": "dummy.txt"
  }
}

// OutputMapFromGitCommand はGitコマンドの結果をMapに変換する
// Goルーチンを使わずに直列処理で実行する
func (executer *serializeExecuter) OutputMapFromGitCommand(resultMap *map[string]interface{}) {
	result := executer.GitCommand()
	start := time.Now()
	// 改行区切りで分割
	lines := strings.Split(result, "\n")
	// lineごとに処理を実行
	for _, line := range lines {
		if line == "" {
			continue
		}
		// パスの文字列をMapに変換
		sampleMap := util.MakeObjectFromPathString(line)
		// Mapをマージ
		util.MergeMaps(resultMap, sampleMap)
	}
	elapsed := time.Since(start)
	fmt.Printf("実行時間: %s\n", elapsed)
}

// OutputMapFromGitCommand はGitコマンドの結果をMapに変換する
// Mutexを使った実装
func (executer *mutexExecuter) OutputMapFromGitCommand(resultMap *map[string]interface{}) {
	result := executer.GitCommand()
	start := time.Now()
	// 追加１：排他制御用のMutex
	var mu sync.Mutex
	// 追加２：ゴルーチンの完了を待つためのWaitGroup
	var wg sync.WaitGroup
	// 改行区切りで分割
	lines := strings.Split(result, "\n")
	// lineごとに処理を実行
	for _, line := range lines {
		if line == "" {
			continue
		}
		// 追加３：WaitingGroupを１つ増やす
		wg.Add(1)
		// 追加４：ゴルーチンを起動
		go func(line string) {
			// 追加５：ゴルーチンが終了したらDoneを呼ぶ
			defer wg.Done()
			// 追加６：マップの更新を排他制御
			mu.Lock()
			// パスの文字列をMapに変換
			singleMap := util.MakeObjectFromPathString(line)
			util.MergeMaps(resultMap, singleMap) // マップをマージ
			// 追加６：マップの更新を排他制御
			mu.Unlock()
		}(line)
	}
	// 追加７：全てのゴルーチンが終了するまで待つ
	wg.Wait()
	elapsed := time.Since(start)
	fmt.Printf("実行時間: %s\n", elapsed)
}

// OutputMapFromGitCommand はGitコマンドの結果をMapに変換する
// チャネルを使った実装
func (executer *channelExecuter) OutputMapFromGitCommand(resultMap *map[string]interface{}) {
	result := executer.GitCommand()
	start := time.Now()
	// 追加１：チャネルの定義(プログラム終了時にチャネルを閉じる)
	channel := make(chan map[string]interface{}, 1)
	// 追加２：Mapに関するチャネルに初期値を代入
	initMap := make(map[string]interface{})
	channel <- initMap
	// ゴルーチンの完了を待つためのWaitGroup
	var wg sync.WaitGroup
	// 改行区切りで分割
	lines := strings.Split(result, "\n")
	// lineごとに処理を実行
	for _, line := range lines {
		if line == "" {
			continue
		}
		// WaitingGroupを１つ増やす
		wg.Add(1)
		go func(line string) {
			// ゴルーチンが終了したらDoneを呼ぶ
			defer wg.Done()
			// 追加３：チャネルから現在のMapを受領
			tmpMap := <-channel
			// パス文字列からマップを作成
			singleMap := util.MakeObjectFromPathString(line)
			util.MergeMaps(&tmpMap, singleMap) // マップをマージ
			// 追加４：マージされたMapをチャネルに書き込み
			channel <- tmpMap
		}(line)
	}
	// 全てのゴルーチンが終了するまで待つ
	wg.Wait()
	// 追加５：最終的な結果を受け取る
	*resultMap = <-channel
	// 追加６：チャネルを閉じる
	close(channel)
	elapsed := time.Since(start)
	fmt.Printf("実行時間: %s\n", elapsed)
}