Go言語のselect文とタイマー機能について解説

package main
import (
	"fmt"
	"time"
)
func main() {
	// サンプル用に2つのチャネルを作成
	channelA := make(chan string)
	channelB := make(chan string)
	// 別ゴルーチンでチャネルにメッセージを送信
	go func() {
		time.Sleep(100 * time.Millisecond)
		channelA <- "チャネルAからのメッセージ"
	}()
	go func() {
		time.Sleep(200 * time.Millisecond)
		channelB <- "チャネルBからのメッセージ"
	}()
	// 複数チャネルの受信処理をselect文で待ち受ける
	for i := 0; i < 2; i++ {
		select {
		case msg := <-channelA:
			fmt.Println(msg) // チャネルAのメッセージを表示
		case msg := <-channelB:
			fmt.Println(msg) // チャネルBのメッセージを表示
		}
	}
}

チャネルAからのメッセージ
チャネルBからのメッセージ

package main
import (
	"fmt"
)
func main() {
	channel := make(chan string)
	select {
	case msg := <-channel:
		fmt.Println("受信:", msg)
	default:
		// どのチャネルも準備できていない場合、ここへ即座に処理が流れる
		fmt.Println("受信準備ができていません")
	}
}

受信準備ができていません

package main
import (
	"fmt"
	"time"
)
func main() {
	// 500ミリ秒後にタイマーが発火
	timer := time.NewTimer(500 * time.Millisecond)
	fmt.Println("タイマーを開始しました")
	// タイマーが発火するまでブロック
	<-timer.C
	fmt.Println("タイマーが完了しました")
}

タイマーを開始しました
タイマーが完了しました

package main
import (
	"fmt"
	"time"
)
func main() {
	// 初期タイマーを300ミリ秒で設定
	timer := time.NewTimer(300 * time.Millisecond)
	// タイマーが完了する前に再設定する例
	go func() {
		time.Sleep(150 * time.Millisecond)
		// タイマーをリセットし、500ミリ秒後に再発火させる
		if timer.Reset(500 * time.Millisecond) {
			fmt.Println("タイマーリセット成功")
		} else {
			fmt.Println("タイマーリセット失敗")
		}
	}()
	<-timer.C
	fmt.Println("タイマーが新たに完了しました")
}

タイマーリセット成功
タイマーが新たに完了しました

package main
import (
	"fmt"
	"time"
)
func main() {
	// 受信用のチャネルを作成
	messageChannel := make(chan string)
	// タイムアウトを設定(1秒後にタイムアウト)
	timeout := time.NewTimer(1 * time.Second)
	// 別ゴルーチンでメッセージを送信(2秒後に送信するため、タイムアウトが先に発生)
	go func() {
		time.Sleep(2 * time.Second)
		messageChannel <- "メッセージ受信"
	}()
	select {
	case msg := <-messageChannel:
		fmt.Println("受信:", msg)
	case <-timeout.C:
		fmt.Println("タイムアウト発生")
	}
}

タイムアウト発生

package main
import (
	"fmt"
	"time"
)
func main() {
	// サービス応答のチャネルを作成
	serviceChannel := make(chan string)
	// タイムアウトを設定(800ミリ秒)
	timeout := time.NewTimer(800 * time.Millisecond)
	go func() {
		// サービス応答のシミュレーション(1秒後に応答)
		time.Sleep(1 * time.Second)
		serviceChannel <- "サービスからの応答"
	}()
	select {
	case res := <-serviceChannel:
		fmt.Println("応答受信:", res)
	case <-timeout.C:
		fmt.Println("タイムアウト発生：サービスの応答が遅延しています")
	}
}

タイムアウト発生：サービスの応答が遅延しています

package main
import (
	"fmt"
	"time"
)
func main() {
	// 複数のサービスから応答を待つチャネルを作成
	serviceChannel1 := make(chan string)
	serviceChannel2 := make(chan string)
	timeout := time.NewTimer(700 * time.Millisecond)
	// サービス1からの応答シミュレーション(1秒後に応答)
	go func() {
		time.Sleep(1 * time.Second)
		serviceChannel1 <- "サービス1の応答"
	}()
	// サービス2からの応答シミュレーション(500ミリ秒後に応答)
	go func() {
		time.Sleep(500 * time.Millisecond)
		serviceChannel2 <- "サービス2の応答"
	}()
	select {
	case res := <-serviceChannel1:
		fmt.Println("サービス1から応答:", res)
	case res := <-serviceChannel2:
		fmt.Println("サービス2から応答:", res)
	case <-timeout.C:
		fmt.Println("タイムアウト：いずれのサービスも応答がありません")
	}
}

サービス2から応答: サービス2の応答