管道(Channel)
1、管道本质就是一个数据结构-队列
2、数据是先进先出
3、自身线程安全,多协程访问时不需要加锁,channel本身就是线程安全的
4、管道有类型的,一个string的管道,只能存放string类型的数据
管道的定义
var 变量名 chan 数据类型
1:chan管道关键字
2:数据类型指的是管道的类型,里面放入数据的类型,管道是有类型的,intChan只能写入整数int
3:管道是引用类型,必须初始化才能写入数据,即make后才能使用
代码
package main
import "fmt"
func main() {
//定义一个int类型的管道
var intChan chan int
//通过make初始化:管道可以存放3个int类型的数据
intChan = make(chan int, 3)
//证明管道是引用类型:
fmt.Printf("intChan的值:%v \n", intChan) //0xc000062080
//向管道存放数据,箭头指向管道:
intChan <- 10
num := 20
intChan <- num
intChan <- 40
//注意:不能存放大于容量的数据
//intChan <- 80
//在管道中读取数据
num1 := <-intChan
num2 := <-intChan
num3 := <-intChan
fmt.Println(num1)
fmt.Println(num2)
fmt.Println(num3)
//注意:在没有使用协程的情况下,如果管道的数据已经全部取出,那么再取就会报错
//num4 := <-intChan
//fmt.Println(num4)
//输出管道的长度:
fmt.Printf("管道的实际长度:%v,管道的容量是:%v", len(intChan), cap(intChan))
}
管道默认是只读只写性质,可以定义只读管道和只写管道
package main
import "fmt"
func main() {
//默认情况下,管道是双向的---》可读可写
//var intChan1 chan int
//声明为只写性质管道:
var intChan2 chan<- int
intChan2 = make(chan int, 3)
intChan2 <- 10
//报错 invalid operation: cannot receive from send-only channel intChan2 (variable of type chan<- int)
//num := <-intChan2
fmt.Println(intChan2)
//声明为只读性质的管道:
var intChan3 <-chan int
if intChan3 != nil {
num := <-intChan3
fmt.Println(num)
}
// 报错
//intChan3 <- 10
}