Go言語のチャネル：ゴルーチン間の通信を理解しよう！

はじめに

Go言語の特徴の一つである「ゴルーチン（goroutine）」は、並行処理を簡単に実装できる強力な機能です。しかし、複数のゴルーチンが同時に実行されると、データの競合やデッドロックといった問題が発生する可能性があります。

そこで登場するのが「チャネル（channel）」です。チャネルは、ゴルーチン間でデータを安全にやり取りするための仕組みです。チャネルを使うことで、ゴルーチン間の同期やデータの共有をスムーズに行うことができます。

今回は、Go言語のチャネルについて、基本的な使い方から応用的な使い方まで、学びながら分かりやすく解説します。

チャネルの基本

チャネルは、特定の型のデータを送受信するためのパイプのようなものです。

チャネルの作成

チャネルは、make関数を使って作成します。

go 
ch := make(chan int)

このコードは、int型のデータを送受信できるチャネルchを作成しています。

データの送信と受信

チャネルへのデータの送信と受信には、<-演算子を使います。

go 
ch <- 10 // チャネルchに10を送信
x := <-ch // チャネルchからデータを受信し、xに代入

チャネルを使ったゴルーチン間の通信

go 
func main() {
    ch := make(chan string)

    go func() {
        ch <- "Hello from goroutine!"
    }()

    msg := <-ch
    fmt.Println(msg) // Hello from goroutine!
}

このコードでは、メインのゴルーチンとは別のゴルーチンでチャネルにメッセージを送信し、メインのゴルーチンでそのメッセージを受信しています。

チャネルの種類

チャネルには、バッファなしチャネルとバッファありチャネルの2種類があります。

バッファなしチャネル

バッファなしチャネルは、データの送信と受信が同時に行われる必要があります。送信側は受信側が準備できるまでブロックされ、受信側は送信側がデータを送信するまでブロックされます。

バッファありチャネル

バッファありチャネルは、指定した数のデータまでバッファに溜めることができます。バッファに空きがある場合は、送信側はブロックされずにデータを送信できます。バッファが満杯の場合は、送信側はブロックされます。

go 
ch := make(chan int, 3) // バッファサイズ3のチャネルを作成

チャネルの応用

select文

select文を使うと、複数のチャネルからの受信を待ち受けることができます。

go 
select {
case msg1 := <-ch1:
    fmt.Println("Received from ch1:", msg1)
case msg2 := <-ch2:
    fmt.Println("Received from ch2:", msg2)
default:
    fmt.Println("No data received")
}

チャネルのクローズ

チャネルを使い終わったら、close関数を使ってクローズすることができます。

go 
close(ch)

チャネルがクローズされると、それ以降はチャネルにデータを送信することはできません。受信側は、チャネルがクローズされたことを検知することができます。

まとめ

チャネルは、Go言語で並行処理を実装する上で非常に重要な機能です。チャネルを使いこなすことで、ゴルーチン間の通信を安全かつ効率的に行うことができます。

参考になったら嬉しいです！

Back to all posts