Go言語で学ぶ並行処理とエラーハンドリングのコツ！初心者でも安心

1. 並行処理とエラーハンドリングの基本

1. 並行処理とエラーハンドリングの基本

Goではgoroutineを使うと、複数の処理を同時に実行できます。しかし、並行処理ではエラーが発生したときに気づきにくい問題があります。そこで、channelを活用してエラーを集約することが大切です。

例えば、複数のURLからデータを取得する場合、それぞれの処理でエラーが発生する可能性があります。各goroutineからエラーをerrChに送信することで、main関数でまとめて確認できます。

2. エラーハンドリングの基本的な実装例

2. エラーハンドリングの基本的な実装例

package main

import (
    "errors"
    "fmt"
    "sync"
)

func worker(id int, errCh chan<- error, wg *sync.WaitGroup) {
    defer wg.Done()
    if id%2 == 0 {
        errCh <- fmt.Errorf("Worker %d でエラー発生", id)
    } else {
        errCh <- nil
    }
}

func main() {
    var wg sync.WaitGroup
    errCh := make(chan error, 5)

    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, errCh, &wg)
    }

    wg.Wait()
    close(errCh)

    for err := range errCh {
        if err != nil {
            fmt.Println("エラー検知:", err)
        } else {
            fmt.Println("処理成功")
        }
    }
}

この例では、5つのWorkerがそれぞれ処理を行い、エラーをerrChに送ります。main関数でchannelを閉じた後、rangeでエラーを確認します。

3. エラーを効率的にまとめるポイント

3. エラーを効率的にまとめるポイント

• バッファ付きchannelを使うと、複数のgoroutineから安全にエラーを送信できる
• Worker Poolを併用するとgoroutineの数を制御し、リソース消費を抑えられる
• sync.WaitGroupで全てのWorkerの終了を待つ
• channelを閉じるタイミングを間違えない
• main goroutineでまとめてエラーを処理し、ログ出力や再試行などを行う

4. 実践的な応用例

4. 実践的な応用例

WebスクレイピングやAPIリクエスト、データベース操作など、複数の処理を並行で実行する場合、Worker Poolとエラー集約channelを組み合わせると非常に便利です。全ての処理で発生したエラーを一元管理できるため、問題発生時に迅速に対応できます。

例えば、複数のAPIに同時リクエストを送る場合、各goroutineからエラー情報を収集し、成功したものと失敗したものをまとめてログに記録したり、再試行したりすることが可能です。

5. エラーハンドリングのベストプラクティス

5. エラーハンドリングのベストプラクティス

• 必ず各goroutineで発生したエラーをmainに通知する
• channelのバッファサイズを適切に設定する
• Worker Poolでgoroutine数を制御しリソースを最適化する
• main goroutineでまとめて処理し、エラーの一元管理を行う
• 必要に応じてリトライやログ出力で安全性を高める

これらのコツを押さえると、Go言語での並行処理が安全で効率的になり、初心者でも安心してプログラムを作成できます。