Go言語のチャネルについて解説：並行処理を効率化する基本機能

package main
import (
	"fmt"
)
func main() {
	// 整数型チャネルの作成(バッファなし)
	ch := make(chan int)
	// ゴルーチンで整数値を送信
	go func() {
		// チャネルに10を送信する
		ch <- 10
	}()
	// チャネルから整数値を受信する
	value := <-ch
	fmt.Println("受信した値:", value)
}

受信した値: 10

package main
import (
	"fmt"
)
func main() {
	// バッファなしチャネル：送信と受信が互いに待機が必要
	nobufferCh := make(chan string)
	// バッファ付きチャネル：サイズ3のバッファを持つ
	bufferCh := make(chan string, 3)
	// バッファなしチャネルの例
	go func() {
		nobufferCh <- "Hello, No Buffer!"
	}()
	fmt.Println("バッファなしチャネルからの受信:", <-nobufferCh)
	// バッファ付きチャネルにデータを連続して送信
	bufferCh <- "Message 1"
	bufferCh <- "Message 2"
	bufferCh <- "Message 3"
	// 受信例：バッファがあるため、順次データを取り出せる
	fmt.Println("バッファ付きチャネルからの受信:")
	for i := 0; i < 3; i++ {
		fmt.Println("  ", <-bufferCh)
	}
}

バッファなしチャネルからの受信: Hello, No Buffer!
バッファ付きチャネルからの受信:
   Message 1
   Message 2
   Message 3

package main
import (
	"fmt"
)
func worker(id int, ch chan int) {
	// ゴルーチン内で計算した結果をチャネルに送信
	result := id * 2
	// 結果を送信
	ch <- result
}
func main() {
	// 整数型チャネルを作成
	ch := make(chan int)
	// 3つのゴルーチンを生成し、各々で計算した結果を送信
	for i := 1; i <= 3; i++ {
		go worker(i, ch)
	}
	// 送信された結果を3つ受信する
	for i := 0; i < 3; i++ {
		result := <-ch
		fmt.Println("受信した結果:", result)
	}
}

受信した結果: 2
受信した結果: 4
受信した結果: 6

package main
import (
	"fmt"
	"time"
)
func sendMessage(ch chan string, message string, delay time.Duration) {
	time.Sleep(delay)
	ch <- message
}
func main() {
	// 2つの文字列型チャネル作成
	ch1 := make(chan string)
	ch2 := make(chan string)
	// ゴルーチンでチャネルへ送信
	go sendMessage(ch1, "メッセージ from ch1", 1*time.Second)
	go sendMessage(ch2, "メッセージ from ch2", 2*time.Second)
	// 2つのチャネルからの受信をselectで待機
	for i := 0; i < 2; i++ {
		select {
		case msg1 := <-ch1:
			fmt.Println("受信:", msg1)
		case msg2 := <-ch2:
			fmt.Println("受信:", msg2)
		}
	}
}

受信: メッセージ from ch1
受信: メッセージ from ch2

package main
import (
	"fmt"
	"time"
)
func main() {
	// バッファなしチャネルを作成(ブロッキングが発生しやすい)
	ch := make(chan int)
	// タイムアウト用のチャネル作成
	timeout := time.After(2 * time.Second)
	// ゴルーチンでチャネルへの送信(受信待ちでブロックされる可能性がある)
	go func() {
		ch <- 42
	}()
	// select文で受信またはタイムアウトをチェック
	select {
	case result := <-ch:
		fmt.Println("受信した値:", result)
	case <-timeout:
		fmt.Println("タイムアウト：データの受信に失敗")
	}
}

受信した値: 42

package main
import (
	"fmt"
)
func main() {
	// 整数型チャネル作成(バッファ付き)
	ch := make(chan int, 3)
	// チャネルに複数の値を送信
	ch <- 1
	ch <- 2
	// 送信が完了したためチャネルを閉じる
	close(ch)
	// チャネルが閉じられているため、rangeで全ての値を受信
	for value := range ch {
		fmt.Println("受信した値:", value)
	}
	// 閉じられたチャネルから受信すると、初期値が返る点に注意
	value, ok := <-ch
	if !ok {
		fmt.Println("チャネルは閉じられています。")
	} else {
		fmt.Println("受信した値:", value)
	}
}

受信した値: 1
受信した値: 2
チャネルは閉じられています。