golang チャンネル – テックメモ

package main

import (
	"fmt"
	"log"
)

func main() {

	//定義
	c := make(chan int)

	/*
		capacityはchannel内でのバッファ
		capacityに空きがないと送信側で処理待ちになる

		非同期の終了待ちは途中で抜けると送信側の処理待ちが残ってしまう

		closeしたチャンネルは操作できない
	*/

	go func(s chan<- int) {

		for i := 0; i < 5; i++ {
			s <- i //送信
		}

		close(s) //受信側でcloseを検知する

	}(c) //即時関数の引数にcを渡している

	//close待ちする場合(非同期の終了待ち)
	<-c

	//for-rangeで受信
	for v := range c {
		fmt.Println(v)
	}

	//forで受信
	//closeの場合okがfalse
	for {
		value, ok := <-c
		if !ok {
			break
		}
		fmt.Println(value)
	}

	//すべて受信(closeの場合0)
	vv := <-c
	log.Print("_", vv)

}

package main

import (

"fmt"

"log"

)

func main() {

//定義

c := make(chan int)

capacityはchannel内でのバッファ

capacityに空きがないと送信側で処理待ちになる

非同期の終了待ちは途中で抜けると送信側の処理待ちが残ってしまう

closeしたチャンネルは操作できない

go func(s chan<- int) {

for i := 0; i < 5; i++ {

s <- i //送信

}

close(s) //受信側でcloseを検知する

}(c) //即時関数の引数にcを渡している

//close待ちする場合(非同期の終了待ち)

<-c

//for-rangeで受信

for v := range c {

fmt.Println(v)

}

//forで受信

//closeの場合okがfalse

for {

value, ok := <-c

if !ok {

break

}

fmt.Println(value)

}

//すべて受信(closeの場合0)

vv := <-c

log.Print("_", vv)

}