GoのSelectチャネルを掘り下げる: Go並行プログラミングテクニック

2年 ago
結衣, 春花
1 minute

Go言語での並列処理技術は、selectキーワードを使用することで実現できます。select文は通信の準備が整ったチャネル操作を選択するもので、複数のチャネル操作から同時に待つことができます。タイムアウト処理や操作のキャンセルなど、並列処理におけるさまざまな問題の解決に使用できます。

select文では、各case文で異なる処理を実行できます。selectは複数のチャネルが通信可能になったとき、その中からランダムに1つ選び、対応した処理を実行します。通信可能なチャネルが1つも無くdefault文がある場合、default文で指定された処理を実行します。default文が無い場合は、チャネルが通信可能になるまでselect文はブロックします。

以下の例は select ステートメントを使用したもので、複数のチャネルのどちらかを選択する方法を示しています:

package main
import (
"fmt"
"time"
)
func main() {
ch1 := make(chan string)
ch2 := make(chan string)
go func() {
time.Sleep(1 * time.Second)
ch1 <- "Hello"
}()
go func() {
time.Sleep(2 * time.Second)
ch2 <- "World"
}()
select {
case msg1 := <-ch1:
fmt.Println("Received:", msg1)
case msg2 := <-ch2:
fmt.Println("Received:", msg2)
}
}

この例では、ch1とch2という2つのチャネルを作成し、それぞれ異なるゴルーチンでチャネルにメッセージを送信します。それからselect文を使って通信する準備ができているチャネルを選択し、受信したメッセージを出力します。

ch1チャネルが通信準備を整えるため、このコードを実行すると「Received: Hello」と表示されます。

select文は単なる通信動作だけでなく、タイムアウト処理やキャンセル処理などの動作と組み合わせて利用できます。たとえば、タイムアウト処理を実現するために、time.After関数を使用してタイマーチャネルを作成し、select文でタイマーチャネルが通信可能になるのを待ちます。

select文を使用する場合、チャネルのクローズやデータの競合アクセスなど、いくつかの並行安全性問題にも注意する必要があります。したがって、select文を詳細に調べる前に、並行プログラミングの基本的な概念と技術をある程度理解しておくことをお勧めします。

bannerAds