Goでセレクトチャネルを使った並行処理におけるエラー処理方法

Goの並列プログラミングでは、select文を使用して複数のチャネルのデータフローを同時に監視し、状況に応じて処理できます。いずれかのチャネルに読み取り可能なデータがあると、select文は実行されるべきケースをランダムに選択します。

エラー処理では、エラーチャネルにエラー情報を送り、select文でエラー処理のケースを追加します。

サンプルコードを示します。

package main
import (
"fmt"
"time"
)
func doWork(input chan string, errCh chan error) {
// 模拟一个工作任务
time.Sleep(2 * time.Second)
// 假设在这里发生了一个错误
err := fmt.Errorf("something went wrong")
errCh <- err
}
func main() {
input := make(chan string)
errCh := make(chan error)
go doWork(input, errCh)
select {
case <-input:
// 处理输入数据
fmt.Println("Received input data")
case err := <-errCh:
// 处理错误
fmt.Println("Received error:", err)
}
}

この例では、doWork関数は作業タスクをシミュレートし、タスクの完了後にデータを入力チャネルに送信しました。その後、doWork関数でエラーが発生し、エラー情報はerrChチャネルから渡されました。

main 関数内で、select 文によって input チャネルと errCh チャネルを監視します。input チャネルに読み取り可能なデータがある場合は入力データを処理し、errCh チャネルにエラー情報がある場合はエラーを処理します。

doWork関数において、エラーが発生しない場合に、nilをerrChチャネルに送信するという選択肢を取ることで、エラーが発生しなかったことを示すことができる点に注意。

Goの並行処理でエラー処理を可能にする手法。この手法は、ブロックやデッドロックの問題を回避し、異なるチャネルからのデータとエラーの同時処理を実現する。