golang 协程通信

func finish(ch chan int){
	fmt.Println("finish")
	ch <- 1

}

func main() {
	// 无缓冲管道 写入后一直阻塞到有人读出
	// 或者在没有数据时读取也会阻塞
	// 采取缓冲信道后变成生产者消费者模型 只有在空或者满时才会发生阻塞
	ch := make(chan int)
	go finish(ch)
	fmt.Println("main finish")
	<- ch
}

func main() {
	chs := make(chan int, 3)
	chs <- 1
	chs <- 2
	chs <- 3
	// 在主线程中 写入满后就会一直阻塞该线程 除非进行读取
	for i:=0;i<3;i++{
		fmt.Println(<-chs)
	}
	// 或者采用range 读取 但是range 在信道关闭之前会一直读取 当使用range读三次后就会发生阻塞
	// 此时可用close显式关闭信道 变成只读 读完就结束了

}

func main() {
	chs := make(chan int, 3)
	chs <- 1
	chs <- 2
	chs <- 3
	// 或者采用range 读取 但是range 在信道关闭之前会一直读取 当使用range读三次后就会发生阻塞
	// 此时可用close显式关闭信道 变成只读 读完就结束了
	close(chs)
	for c:= range chs{
		fmt.Println(c)
	}

}

func Count(ch chan int){
	fmt.Println("Counting")
	ch <- 1

}


func main() {
	count := 100
	ch := make(chan int)
	for i:=0;i<count;i++{
		go Count(ch)
	}
	// 此时100个Count并发后阻塞 每读出一个执行完一个
	for i:=0;i<count;i++{
		<-ch
	}
}

func Count(ch chan int){
	fmt.Println("Counting")
	ch <- 1

}


func main() {
	count := 100
	ch := make(chan int,count)
	for i:=0;i<count;i++{
		go Count(ch)
	}

	for i:=0;i<count;i++{
		<-ch
	}
}

同时select 类似linux中的select 监听信道 当有信道写入时对应的case将执行 多个都满足时随机选择一个执行

select {
    case <- chan1:
    // 如果chan1成功读到数据
    
    case chan2 <- 1:
    // 如果成功向chan2写入数据

    default:
    // 默认分支
}