Go言語のチャネル(chan)の基本と活用法を解説

package main
import "fmt"
func main() {
	// チャネルの宣言(整数型)
	ch := make(chan int)
	// goroutineで値を送信する
	go func() {
		// チャネルに値を送信
		ch <- 100  // 送信
	}()
	// チャネルから値を受信
	value := <-ch  // 受信
	fmt.Println("受信した値:", value)
}

受信した値: 100

package main
import "fmt"
func main() {
	// バッファなしチャネルを生成
	ch := make(chan string)
	// goroutineでメッセージ送信
	go func() {
		// "Hello"をチャネルに送信
		ch <- "Hello"
	}()
	// メイン側で値を受信
	message := <-ch
	fmt.Println("受信メッセージ:", message)
}

受信メッセージ: Hello

package main
import "fmt"
func main() {
	// バッファありチャネルを生成(バッファサイズ3)
	ch := make(chan int, 3)
	// バッファの空きがあるため、受信待ちがなくとも送信可能
	ch <- 10
	ch <- 20
	ch <- 30
	// バッファが満杯でも後から受信すれば正常に取得ができる
	fmt.Println("チャネルからの値1:", <-ch)
	fmt.Println("チャネルからの値2:", <-ch)
	fmt.Println("チャネルからの値3:", <-ch)
}

チャネルからの値1: 10
チャネルからの値2: 20
チャネルからの値3: 30

package main
import (
	"fmt"
)
// add関数：2つの数値の合計を計算
func add(a, b int, ch chan int) {
	ch <- a + b  // 結果をチャネルで送信
}
func main() {
	// 結果受信用チャネルを生成
	resultChannel := make(chan int)
	// goroutineで別々の計算処理を実行
	go add(10, 20, resultChannel)
	go add(30, 40, resultChannel)
	// 二つのgoroutineから結果を受信して表示
	sum1 := <-resultChannel
	sum2 := <-resultChannel
	fmt.Println("計算結果1:", sum1)
	fmt.Println("計算結果2:", sum2)
}

計算結果1: 30
計算結果2: 70

package main
import (
	"fmt"
	"time"
)
func main() {
	// 二つのチャネルを生成
	ch1 := make(chan string)
	ch2 := make(chan string)
	// goroutineでそれぞれメッセージを送信
	go func() {
		// 少し遅れてメッセージ送信
		time.Sleep(100 * time.Millisecond)
		ch1 <- "Message from ch1"
	}()
	go func() {
		// さらに遅れてメッセージ送信
		time.Sleep(200 * time.Millisecond)
		ch2 <- "Message from ch2"
	}()
	// select文で受信処理
	select {
	case msg := <-ch1:
		fmt.Println("受信:", msg)
	case msg := <-ch2:
		fmt.Println("受信:", msg)
	}
}

受信: Message from ch1

package main
import (
	"fmt"
	"time"
)
func main() {
	// チャネルを生成
	ch := make(chan string)
	// goroutineで遅延してメッセージ送信
	go func() {
		// 300ミリ秒後に送信
		time.Sleep(300 * time.Millisecond)
		ch <- "Delayed message"
	}()
	// タイムアウトの設定(200ミリ秒)
	select {
	case msg := <-ch:
		fmt.Println("受信メッセージ:", msg)
	case <-time.After(200 * time.Millisecond):
		fmt.Println("タイムアウト発生")
	}
}

タイムアウト発生

package main
import "fmt"
func main() {
	// 整数型チャネルを生成
	ch := make(chan int, 2)
	// 複数の値を送信
	ch <- 1
	ch <- 2
	// チャネルをクローズ
	close(ch)
	// クローズされたチャネルから全ての値を受信
	for {
		value, ok := <-ch
		if !ok {
			// チャネルがクローズされた場合、ループを終了
			break
		}
		fmt.Println("受信した値:", value)
	}
}

受信した値: 1
受信した値: 2

package main
import (
	"fmt"
	"math/rand"
	"time"
)
// worker関数：ランダムな数値を計算してチャネルに送信
func worker(id int, ch chan int) {
	// ランダムな遅延をシミュレート
	time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
	result := id * 10  // シンプルな計算
	ch <- result
}
func main() {
	// ワーカーの数を定義
	workerCount := 5
	results := make(chan int, workerCount)
	// 複数のworkerを生成し、並行実行
	for i := 1; i <= workerCount; i++ {
		go worker(i, results)
	}
	// 全ての結果を受信して表示
	for i := 1; i <= workerCount; i++ {
		fmt.Println("Workerの結果:", <-results)
	}
}

Workerの結果: 50
Workerの結果: 20
Workerの結果: 10
Workerの結果: 30
Workerの結果: 40