Merge pull request #1564 from future-architect/feature

sync

Author: ma91n

source/_posts/20250730a_Go_1.25リリース連載始まります_&_trace.FlightRecorder.md

@@ -21,7 +21,7 @@ Go 1.25 のリリースが近づいてきました。今回は比較的シンプ
 | :--: | :--------------- | :--------- |
 | 7/30 | この記事         | 渋川       |
 | 7/31 | [log/slog](/articles/20250731a/)         | 武田さん   |
-| 8/1  | sync             | 辻さん     |
+| 8/1  | [sync](/articles/20250801a/)             | 辻さん     |
 | 8/4  | net/http         | 島ノ江さん |
 | 8/5  | testing/synctest | 市川燿さん |
 | 8/6  | json/v2          | 後藤さん   |

source/_posts/20250801a_Go1.25リリース連載：sync.md

@@ -0,0 +1,135 @@
+---
+title: "Go1.25リリース連載：sync"
+date: 2025/08/01 00:00:00
+postid: a
+tag:
+  - Go
+  - Go1.25
+category:
+  - Programming
+thumbnail: /images/20250801a/thumbnail.jpg
+author: 辻大志郎
+lede: "Go 1.25のマイナーアップデートから sync パッケージを取り上げて紹介します。"
+---
+<img src="/images/20250801a/top.jpg" alt="" width="1024" height="599">
+
+# はじめに
+
+製造エネルギー事業部の辻です。[Go1.25 リリース連載](/articles/20250730a/) の3本目です。
+
+マイナーアップデートから [`sync`](https://pkg.go.dev/[email protected]) パッケージを取り上げて紹介します。
+
+# アップデートサマリ
+
+> The new method on WaitGroup, WaitGroup.Go, makes the common pattern of creating and counting goroutines more convenient.
+
+https://go.dev/doc/go1.25#syncpkgsync
+
+`sync` パッケージに新しく `WaitGroup.Go()` というメソッドが追加されました。ゴルーチンの生成と完了を集計する一般的なパターンを便利に記述できるようになりました。
+
+<div class="note info" style="background: #e5f8e2; padding:16px; margin:24px 12px; border-radius:8px;"><span class="fa fa-fw fa-check-circle"></span>
+
+このメソッドを利用すると、たとえば以下のような並行処理のコードをより簡潔に記述できるようになります。
+
+```go Go1.24以前
+	var wg sync.WaitGroup
+	tasks := []string{"task 1", "task 2", "task 3"}
+
+	for _, t := range tasks {
+		// 1. ゴルーチン起動前にカウンタをインクリメント
+		wg.Add(1)
+
+		go func(task string) {
+			// 2. ゴルーチン終了時にカウンタをデクリメント
+			defer wg.Done()
+			fmt.Printf("Executing %s\n", task)
+		}(t)
+	}
+
+	wg.Wait()
+	fmt.Println("All tasks completed.")
+}
+```
+
+```go Go1.25
+	var wg sync.WaitGroup
+	tasks := []string{"task 1", "task 2", "task 3"}
+
+	for _, t := range tasks {
+		// wg.Go() を呼び出すだけでOK
+		wg.Go(func() {
+			fmt.Printf("Executing %s\n", t)
+		})
+	}
+
+	wg.Wait()
+	fmt.Println("All tasks completed.")
+```
+
+</div>
+
+なお、`go vet` の静的解析で ` sync.WaitGroup.Add()` のミスパターンの検知ができるようになりました。こちらは真野さんの記事で解説予定ですので本記事では割愛します。
+
+# 背景など
+
+関連するIssueは [#63796：sync: add WaitGroup.Go](https://github.com/golang/go/issues/63796) です。
+
+Go の並行処理の実装パターンとして以下のようなコードがよく見られます。
+
+```go
+	var wg sync.WaitGroup
+	for i := 1; i <= 5; i++ {
+		// i := i この変数の確保は Go1.22 で不要になっています
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+			work(i)
+		}()
+	}
+	wg.Wait()
+```
+
+実装として `wg.Add(1)` や `defer wg.Done()` は必要ですが、忘れがちなミスパターンの一つでもあります。
+
+<div class="note info" style="background: #e5f8e2; padding:16px; margin:24px 12px; border-radius:8px;"><span class="fa fa-fw fa-check-circle"></span>
+
+なおGo1.21以前はループ変数をクロージャで扱う際にコード内で明示的に `i := i` などしてメモリ確保が必要でしたが、Go1.22以降はGo側でよしなにメモリを確保できるようになっており、アプリ開発者が `i := i` とする実装は不要になっています。
+
+</div>
+
+今回のリリースされる `WaitGroup.Go()` メソッドで、上記のようなパターンをカプセル化し、Goの並行処理をより簡潔に実装できるようになります。以下が `WaitGroup.Go()` メソッドの実装です。
+
+```go
+func (wg *WaitGroup) Go(f func()) {
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		f()
+	}()
+}
+```
+
+https://cs.opensource.google/go/go/+/release-branch.go1.25:src/sync/waitgroup.go;l=235-241
+
+# errgroup との違いは？
+
+Goの並行処理の実装をするときに準標準ライブラリである [`golang.org/x/sync/errgroup`](https://pkg.go.dev/golang.org/x/sync/errgroup) パッケージを利用されている方もいるのではないか、と思います。私も `errgroup` にはよくお世話になっています。
+
+`errgroup` パッケージは標準ライブラリである `sync` パッケージに依存しています。`sync` パッケージはより低レイヤーなパッケージと言えますが、並行処理を扱う上で以下のような機能的な違いがあります。
+
+|特徴|sync.WaitGroup (と Go メソッド)|golang.org/x/sync/errgroup|
+|:----|:----|:----|
+|主な目的|全てのゴルーチンの完了を待機|全てのゴルーチンの完了を待機 + 最初のエラーを伝播 + キャンセル|
+|エラー処理|Goメソッドには存在しない。必要に応じて個々のゴルーチンで実装、呼び出し元との連携はチャネル等を利用|最初のエラーを自動的に捕捉・伝播|
+|キャンセル|なし| `context.Context` と連携し、エラー発生時に他のゴルーチンをキャンセル|
+|同時実行数制御|チャネル等で実装が必要| [`SetLimit()`](https://pkg.go.dev/golang.org/x/sync/errgroup#Group.SetLimit) で指定可能|
+
+上記からもわかるように今回導入される `WaitGroup.Go()` メソッドが既存の `errgroup` パッケージを代替するものか？というとそうではなさそうです。
+
+高機能なAPIを提供するという意味で `errgroup` パッケージは今後も使われるのではないか、と思います。一方、シンプルな機能で十分な場合や、ゴルーチンで発生するすべてのエラーを収集したい場合は `WaitGroup.Go()` とチャネルを利用した実装が必要でしょう。
+
+# まとめ
+
+Go 1.25で `sync` パッケージの `WaitGroup.Go()` メソッドを紹介しました。
+
+エラーハンドリングやコンテキストの伝播、同時実行数制御が必要な場合では引き続き `errgroup` が便利ですが、シンプルな処理であれば `WaitGroup.Go()` が有用になるでしょう。