码迷,mamicode.com
首页 > 其他好文 > 详细

Go之Channel详解

时间:2015-10-12 12:13:31      阅读:147      评论:0      收藏:0      [点我收藏+]

标签:

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详解

标签:

原文地址:http://www.cnblogs.com/anbylau2130/p/4870982.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!