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

先生と生徒の会話形式で理解しよう

生徒

「先生、Goで複数の処理を同時に実行すると便利ですが、途中でエラーが起きたらどうすればいいですか？」

先生

「それは良い質問です。Goではgoroutineを使った並行処理でエラーを安全に扱う方法があります。channelを使ってエラーを集約し、適切に処理するのがコツです。」

生徒

「具体的にはどのようにエラーを扱うのですか？」

先生

「Worker Poolやgoroutineを使う場合、各処理のエラーをerrChのような専用channelに送信し、main goroutineでまとめて確認します。」

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

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

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

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でエラーを確認します。