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

巴特西

Go之Channel详解

最新文章

热门文章