Go之Channel详解

channel取数据时未被赋值将被阻塞，可使用这一机制来完成事件的监听

　　　　 wg := new(sync.WaitGroup)
	wg.Add(2)
	event := make(chan bool)
	//函数
	go func() {
		defer wg.Done()
		for i := 0; i < 5; i++ {
			fmt.Println("触发事件前", i)
		}
		event <- true //触发事件
	}()
	go func() {
		<-event
		defer wg.Done()
		for i := 0; i < 5; i++ {
			fmt.Println("触发事件后", i)
		}

	}()

	wg.Wait()

输出：

触发事件前 0
触发事件前 1
触发事件前 2
触发事件前 3
触发事件前 4
触发事件后 0
触发事件后 1
触发事件后 2
触发事件后 3
触发事件后 4

 

在使用Channel时要注意

若是chan的容量已满，将会发生死锁

如：

 

data:=make(chan int ,3)

exit:=make(chan bool)

data<-1

data<-2

data<-3

data<-4//运行到这里将被阻塞，由于chan容量已满

　

len返回chan中未被读取的元素数量，cap返回缓冲区大小，close关闭当前chan

 

 

判断chan是否关闭

for{

　　if d,ok:=<-data;ok}{

　　　　fmt.Println(d)
　　}else{

　　　　break
　　}

}

　　

 

单向chan：只负责接收，或者只负责发送

至关于分离了chan的发送和接收，将其变为两个便于控制的变量

c := make(chan int, 3)
var send chan<- int = c // send-only
var recv <-chan int = c // receive-only
send <- 1
<-recv