Go言語では、goroutineやchannelといった標準機能により、シンプルかつパワフルな並行処理の実装が可能です。しかし、実務的な開発では、これらの基本要素を適切に組み合わせて可読性・保守性の高いコードを書くことが求められます。その中でよく使われる並行処理の「設計パターン」の一つにFan-out/Fan-inパターンがあります。
本記事では、Fan-out/Fan-inパターンを中心に、どのような場面で有効か、また実装例を示しながら解説します。
Fan-out/Fan-inパターンとは
Fan-outは、1つの入力ストリームや入力イベントに対して、「複数のgoroutineで並行に処理を広げる」ことを指します。例えば、ある仕事キューからタスクを読み取り、それらを複数のワーカー(goroutine)に振り分けて同時並行で処理する場面がFan-outパターンです。
例：
ユーザーからのリクエストを受け取り、その処理を複数のバックエンドサービスに並行問い合わせする。
複数のファイルを同時にパース・解析する。
CPUコア数に応じて複数のgoroutineで計算タスクを並列実行する。
Fan-inとは？
Fan-inは、複数の並行処理（goroutine）からの結果を一つのチャンネルなどに集約するパターンです。Fan-outで拡散された処理が終わったら、そのすべての結果をまとめ上げ、後続の処理に渡せます。これにより、並行処理後に一括して結果を処理したり、最終的な集約ステップを行うことが可能になります。
例：
複数の外部API問い合わせ結果を全て受け取り、レスポンスを統合してクライアントに返す。
並行処理されたデータ解析結果をまとめて集計する。
つまり、Fan-out/Fan-inパターンは「入力(1点) → 並行処理(多点) → 集約(1点)」という一連の流れを上手にモデル化することで、コードを整然とした並行パイプラインに仕上げる手法です。
Fan-out/Fan-inパターンの利点
並行処理の分業化：
タスクを複数のgoroutineに分配することで、I/O待機やCPU計算を並行に行い、スループットが向上します。
スケール性・柔軟性：
処理負荷が増えた場合、ワーカーgoroutineを増やすことで対処しやすいです。
コードの明確化：
入力ステップ(Fan-out)、処理ステップ(ワーカー群)、集約ステップ(Fan-in)が明確に分離されるため、並行フローが理解しやすくなります。
Fan-out/Fan-inパターンの実装例
以下に、簡易的な実装例を示します。ここでは以下の処理をモデルとします。
入力となる一連のタスク（整数値のスライス）を受け取り、それぞれについて「擬似的な重い計算」を並行に行うワーカーを複数稼働させ、結果を最終的に集約する。
package main
import (
"fmt"
"math/rand"
"time"
)
// 擬似的な重い処理
func heavyWork(n int) int {
// ランダムな時間待機しているふり
time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
return n * n
}
func main() {
rand.Seed(time.Now().UnixNano())
inputs := []int{1, 2, 3, 4, 5}
// Fan-out: inputsをワーカー達に振り分ける
numWorkers := 3
inCh := make(chan int)
outCh := make(chan int)
// ワーカー起動
for i := 0; i < numWorkers; i++ {
go func() {
for n := range inCh {
result := heavyWork(n)
outCh <- result
}
}()
}
// 入力をinChに投入(Fan-outの開始)
go func() {
for _, n := range inputs {
inCh <- n
}
close(inCh)
}()
// Fan-in: 複数ワーカーからの結果を集約
results := make([]int, 0, len(inputs))
for i := 0; i < len(inputs); i++ {
res := <-outCh
results = append(results, res)
}
// 全ての結果が集まったので、ここから集約・処理を行う
fmt.Println("Results:", results)
}
コードの解説
入力と出力チャネル：
inChはワーカーへ仕事を渡すためのチャネル、outChはワーカーからの結果を受け取るためのチャネルです。
ワーカー群の起動 (Fan-out)：
for i := 0; i < numWorkers; i++ { ... }で複数のgoroutineを起動し、それぞれがinChから仕事を受け取り処理結果をoutChに送るという単純なロジックを持っています。
入力をinChへ供給：
go func()で別goroutineを起動し、inputsをinChへ順次投入し終わった後にclose(inCh)しています。これによりワーカー側はinChのクローズを感知すると処理終了できます。
出力を受け取り集約 (Fan-in)：
メインgoroutineはlen(inputs)回outChから受信し、すべてのワーカー処理が完了するのを待ちます。この部分がFan-in処理にあたります。
この設計により、ワーカー数や処理負荷を簡単に調整できます。また、処理の流れが明確なので並行処理ロジックが理解しやすく、保守性も向上します。
その他の並行処理パターン
Pipelineパターン：
処理を段階的に分け、複数の段階をチャネルでつなぐことで、データストリームをパイプラインのように流す手法。各ステージをgoroutineで並行処理できるため、段階的に非同期処理を組み上げやすい。
Worker Poolパターン：
Fan-out/Fan-inパターンの一部とも言えるが、一定数のワーカーgoroutineをプールして仕事を割り当てるパターン。スレッドプール的な概念で、リソースの効率的な活用を狙う。
Selectパターン：
複数のチャネルを同時に待ち受けて、到着したデータに応じて処理を行うselect文を活用する。非同期I/Oや複数のイベントを待機して処理を分岐する際に便利。
これらのパターンは、goroutineやchannelの基本に立脚しており、組み合わせることでさらに柔軟でスケーラブルな並行処理設計が可能になります。
まとめ
Fan-out/Fan-inパターンは、一つの入力を複数goroutineで並行処理し（Fan-out）、結果を一箇所に集約する（Fan-in）設計パターンです。
このパターンを使うことで、スループット向上や柔軟なスケールアウト、コードの見通しの良さを実現できます。
PipelineやWorker Poolなど、Goの並行処理では他にも多くのパターンが存在しますが、すべてはgoroutineとchannelという基本要素の理解から始まります。
Fan-out/Fan-inパターンを活用して、より効果的な並行処理設計を行ってみてください！