需要注意的是,go语言中channel本省也是一个原生类型,与map之类的类型一样,因此channel本省在定义后也可以通过channel来传递
可以使用这个特性来实现pipe特性,管道也是使用非常广泛的一种设计模式,比如在处理数据时,可以采用管道设计,这样可以比较容易以插件的方式增加数据的处理流程
下面利用channel可被传递的特性来实现管道。
type PipeData struct {
value int
handler func(int) int
next chan int
}
然后写一个常规的处理函数,只要定义一系列的PipeData的数据并一起传递给这个函数,就可以达到流程处理数据的目的
func handle(queue chan * PipeData) {
for data := range queue {
data.next <- data.handle(data.value)
}
}
利用channel这个可传递性,可以显示非常强大,灵活的系统架构。
单项channel,单项chan只能用于发送或者接收数据,本身必然是同时支持读写的。所谓单向chan只是对chan的一种使用限制
在将一个channel变量传递给一个函数时,可以通过将其指定为单想chan变量,从而限制该函数中可以对此chan的操作
var ch1 chan int ch1是一个正常的chan,不是单向的
var ch2 chan <- float64 ch2是一个单向chan,只用于写float64
var ch3 <- chan int ch3是单向chan只用于读取int数据
单向chan的初始化,chan是一个原生类型,不仅支持被传递,还支持类型转换。
ch4 := make(chan int)
ch5 := <- chan int (ch4) //ch5就是一个单向读取的chan
ch6 := chan <- int(ch4) //ch6是一个单向写入chan
基于ch4通过类型转换初始化了两个单向chan,单向读取的ch5和单向写的ch6。
func Parse (ch <- chan int){
for value := range ch {
fmt.Println("解析后的值:",vlaue)
}
}
除非这个函数的实现着使用了类型转化,否则这个函数就不会因为各种原因对chan进行写。
关闭channel
关闭channel非常简单,直接使用Go语言内置的close()函数即可
close(ch)
介绍了如何关闭chan之后,如果判断一个chan时候已经被关闭?
可以在读取的时候使用多重返回值的方式 x,ok :=<-ch