Goで拡張可能なSelectチャネルを設計する方法を知る

1年 ago
綾乃, 一希
1 minute

Go言語では、スケーラブルな並行プログラミングを実現するためにselect文を使用できます。select文は複数のチャネルの操作を監視し、そのうちのいずれかが操作可能になると処理を行います。

拡張可能なselectチャネルの並列処理を設計するための手順は次のとおりです。

  1. 監視対象のチャンネルを作成します: まず、監視する必要があるチャンネルを作成し、それを並行したゴールーティンに渡す必要があります。
  2. select文によるチャネルのリッスン: メインゴルーチン内ではselect文を用いて、あらゆるチャネル操作の監視を行います。select文は複数のチャネル操作を同時に監視し、いずれか1つが操作可能になった時点で対応処理を実行します。
  3. goルーチン内でのチャネル操作: 同時に動作するgoルーチンでチャネル操作 (データ送信、データ受信など) を行います。チャネル操作が完了すると、チャネル経由で結果がメインのgoルーチンに渡されます。
  4. select文でチャンネル操作を処理する: select文でcase文を使用し、各チャンネルの操作を処理します。某个のチャンネルが操作可能になると、それに応じたcase文が実行され、相应の処理を行います。

Go言語で拡張可能なselectチャネルを伴う同時実行プログラミングを設計する方法の簡単なサンプルコードを次に示します。

package main
import (
"fmt"
"time"
)
func main() {
ch1 := make(chan int)
ch2 := make(chan int)
go func() {
time.Sleep(1 * time.Second)
ch1 <- 1
}()
go func() {
time.Sleep(2 * time.Second)
ch2 <- 2
}()
select {
case <-ch1:
fmt.Println("Received from ch1")
case <-ch2:
fmt.Println("Received from ch2")
case <-time.After(3 * time.Second):
fmt.Println("Timeout")
}
}

上記のサンプルでは、ch1とch2という2つのチャネルを作成し、2つの並行なgoroutineで各チャネルにデータを送信しています。select文を使用してこれらの2つのチャネルに対する処理を待ち受け、いずれか一方のチャネルが処理可能になると、それに応じた処理を実行します。この例では、ch1のデータが先に到着するため、「Received from ch1」のプリント処理を実行します。

select文中のcase文は、記載順に処理される点に注意が必要です。 複数のチャネルが同時に処理可能な場合、select文ではランダムにいずれかのcase文が処理されます。 操作可能なチャネルがひとつもなく、default文がある場合は、default文が実行されます。

select文を使って複数のチャネルを待ち受け処理することで、拡張性のある並行処理が容易に実現できます。

bannerAds