Goのselect文におけるチャネル優先処理について解説

package main
import (
	"fmt"
	"time"
)
func main() {
	// 2つのチャネルを作成
	ch1 := make(chan string)
	ch2 := make(chan string)
	// ゴルーチンでそれぞれのチャネルに値を送信
	go func() {
		// 少し遅延させてから値を送信
		time.Sleep(100 * time.Millisecond)
		ch1 <- "チャネル1からのメッセージ"
	}()
	go func() {
		// 少し早めに値を送信
		time.Sleep(50 * time.Millisecond)
		ch2 <- "チャネル2からのメッセージ"
	}()
	// select文でどちらかのチャネルが返す値を受信
	select {
	case msg := <-ch1:
		fmt.Println("受信:" , msg)
	case msg := <-ch2:
		fmt.Println("受信:" , msg)
		// defaultケースがないため、どちらかのチャネルが値を送るのを待つ
	}
}

受信: チャネル2からのメッセージ

package main
import (
	"fmt"
)
func main() {
	// 2つのチャネルを作成し、受信可能な状態にするためバッファを用意
	ch1 := make(chan string, 1)
	ch2 := make(chan string, 1)
	// 両方のチャネルにあらかじめ値をセット
	ch1 <- "値1"
	ch2 <- "値2"
	// 複数のチャネルから同時に受信できる場合、どちらが選ばれるかはランダム
	select {
	case msg := <-ch1:
		fmt.Println("受信:", msg)
	case msg := <-ch2:
		fmt.Println("受信:", msg)
	}
}

受信: 値1

受信: 値2

package main
import (
	"fmt"
	"time"
)
func main() {
	// チャネルを作成
	priorityCh := make(chan string, 1)
	normalCh := make(chan string, 1)
	// 優先チャネルに値を送信
	priorityCh <- "優先チャネルからのメッセージ"
	// 少し遅延させて通常チャネルに値を送信
	go func() {
		time.Sleep(50 * time.Millisecond)
		normalCh <- "通常チャネルからのメッセージ"
	}()
	// 優先チャネルの状態確認
	select {
	case msg := <-priorityCh:
		fmt.Println("受信:", msg)
	default:
		// 優先チャネルに値がない場合は通常チャネルを確認
		select {
		case msg := <-normalCh:
			fmt.Println("受信:", msg)
		}
	}
}

受信: 優先チャネルからのメッセージ

package main
import (
	"fmt"
)
func main() {
	priorityCh := make(chan string, 1)
	normalCh := make(chan string, 1)
	// フラグにより優先処理の有無を制御
	isPriority := true
	// 両方のチャネルに値をセット
	priorityCh <- "優先チャネルからのデータ"
	normalCh <- "通常チャネルからのデータ"
	if isPriority {
		// 優先フラグが立っている場合は優先チャネルを先に確認
		select {
		case msg := <-priorityCh:
			fmt.Println("受信:", msg)
		default:
			select {
			case msg := <-normalCh:
				fmt.Println("受信:", msg)
			}
		}
	} else {
		// 優先フラグが立っていない場合は通常のselect文を実行
		select {
		case msg := <-normalCh:
			fmt.Println("受信:", msg)
		case msg := <-priorityCh:
			fmt.Println("受信:", msg)
		}
	}
}

受信: 優先チャネルからのデータ

package main
import (
	"fmt"
	"time"
)
func main() {
	emergencyCh := make(chan string, 1)
	normalCh := make(chan string, 1)
	// 非緊急データをあらかじめセット
	normalCh <- "通常データ"
	// ゴルーチンで緊急データを一定時間後に送信
	go func() {
		time.Sleep(100 * time.Millisecond)
		emergencyCh <- "緊急データ"
	}()
	// ループで動的に状態を監視
	for i := 0; i < 2; i++ {
		select {
		// 緊急データがあれば優先的に処理
		case msg := <-emergencyCh:
			fmt.Println("緊急受信:", msg)
		// 通常データも状況に応じて処理
		case msg := <-normalCh:
			fmt.Println("通常受信:", msg)
		default:
			fmt.Println("待機中...")
			time.Sleep(50 * time.Millisecond)
		}
	}
}

通常受信: 通常データ
緊急受信: 緊急データ

package main
import (
	"fmt"
	"sync"
	"time"
)
func main() {
	var wg sync.WaitGroup
	ch := make(chan string, 2)
	// ゴルーチン1
	wg.Add(1)
	go func() {
		defer wg.Done()
		time.Sleep(100 * time.Millisecond)
		ch <- "ゴルーチン1の結果"
	}()
	// ゴルーチン2
	wg.Add(1)
	go func() {
		defer wg.Done()
		time.Sleep(50 * time.Millisecond)
		ch <- "ゴルーチン2の結果"
	}()
	// 全ゴルーチンの終了を待機する
	wg.Wait()
	close(ch)
	// チャネルから受信して順次処理
	for msg := range ch {
		fmt.Println("受信:", msg)
	}
}

受信: ゴルーチン2の結果
受信: ゴルーチン1の結果

package main
import (
	"fmt"
	"time"
)
// processChannelsは、緊急チャネルと通常チャネルからデータを受信する処理をまとめた関数です。
// 優先的に緊急チャネルをチェックし、無ければ通常チャネルを確認します。
func processChannels(emergencyCh, normalCh chan string) {
	select {
	case msg := <-emergencyCh:
		fmt.Println("緊急受信:", msg)
	case msg := <-normalCh:
		fmt.Println("通常受信:", msg)
	default:
		fmt.Println("データ待機中...")
	}
}
func main() {
	emergencyCh := make(chan string, 1)
	normalCh := make(chan string, 1)
	// サンプルデータのセット
	emergencyCh <- "即時対応が必要なデータ"
	normalCh <- "通常のデータ"
	// 状況に応じたチャネル処理
	processChannels(emergencyCh, normalCh)
	// 状況を変えて再度処理を実行
	time.Sleep(100 * time.Millisecond)
	processChannels(emergencyCh, normalCh)
}

緊急受信: 即時対応が必要なデータ
通常受信: 通常のデータ