当前位置：首页 > news >正文

# Go学习-Day9

news 2025/7/4 9:29:32

文章目录

- Channel
- - 声明
  - 存入取出
  - 一个简单的死锁分析

个人博客：CSDN博客

Channel

Channel本质是一个队列
多goroutine访问时不需要加锁，Channel天然线程安全
channel有类型，只能写入相同类型
channel是引用类型
channel必须初始化才能写入数据，make分配内存

声明

	var intChan chan intintChan = make(chan int, 3)

java不是很熟悉，感觉chan有点像java的原子类

存入取出

intChan<- xxx //存入
a := <= intChan//取出

管道不会自然增长，不能超过容量，不能从空的管道里取出数据，会上DeadLock
如果想要存储任意类型的管道，可以用空借口
```
var allChan chan interface{}
```
但是，取出的时候注意类型断言
```
close(intChan)
```
channel关闭之后就不能再写入了，但是能继续读出
关闭之后能用for-range来遍历，如果不关闭的话会出现死锁
死锁的情况很多，建议多找几篇文章看看，写写实操一下
空的缓冲chan相当于无缓冲的chan，无缓冲的chan需要接收者，传入者，否则就会死锁，注意及时关闭
只向管道内写入，不读取就会deadlock，读得慢没有关系
关键是要给每个管道安排一个发送者，和接收者！！！

一个简单的死锁分析

package mainimport ("fmt""time"
)func write(intChan chan int) {for i := 0; i < 5; i++ {fmt.Println("写入: ", i)intChan <- itime.Sleep(time.Second)}//close(intChan)
}func read(intChan chan int, exitChan chan bool) {for {val, ok := <-intChanif !ok {break}fmt.Println("读到", val)}exitChan <- trueclose(exitChan)
}
func main() {intChan := make(chan int, 20)exitChan := make(chan bool, 1)go write(intChan)go read(intChan, exitChan)for {_, ok := <-exitChanif !ok {break}}
}

输出

写入:  0
读到 0
写入:  1
读到 1
写入:  2
读到 2
写入:  3
读到 3
写入:  4
读到 4
fatal error: all goroutines are asleep - deadlock!goroutine 1 [chan receive]:
main.main()E:/JetBrains/GoLandSpace/src/go_code/project01/main/hello.go:36 +0xe8goroutine 7 [chan receive]:
main.read(0x0?, 0x0?)E:/JetBrains/GoLandSpace/src/go_code/project01/main/hello.go:19 +0x99
created by main.mainE:/JetBrains/GoLandSpace/src/go_code/project01/main/hello.go:33 +0xd9Process finished with the exit code 2

下面是个人的分析，不一定对，有大佬可以来指正
如果我们不close，channel是可以读的，我们可以边读，边写，并且，读的速度是可以更慢或者更快的，go底层会通过上下文自行判断。
但是这里，我们写的协程，我们关闭channel，在程序运行完之后自行关闭，此时我们读的协程会卡在intChan，等待读入，但是此时还不会报错，因为协程会因为主线程结束而结束。但是后面的exitChan会导致报错

package mainimport ("fmt""time"
)func write(intChan chan int) {for i := 0; i < 5; i++ {fmt.Println("写入: ", i)intChan <- itime.Sleep(time.Second)}//close(intChan)
}func read(intChan chan int, exitChan chan bool) {for {val, ok := <-intChanif !ok {break}fmt.Println("读到", val)}fmt.Println("到了这里")//exitChan <- true//close(exitChan)
}
func main() {intChan := make(chan int, 20)exitChan := make(chan bool, 1)go write(intChan)go read(intChan, exitChan)time.Sleep(time.Second * 10)//for {//	_, ok := <-exitChan//	if !ok {//		break//	}//}
}