一文玩转go语言中的channel

Posted 2021-11-12 我想月薪过万

可以说 channel（管道） 是go语言中的一大特色，对于初学者来说，使用起来的确有点费劲，本文从案例下手，来引导大家如何使用。

注意点一：管道是引用类型，使用之前得make

//测试代码
package main

func main() {
	// chan int 我们应该把它看作一个整体，他就代表一个数据类型
	var intChan chan int
	intChan <- 1
}


//测试结果
PS E:\\project\\src\\go_dev\\day14\\demo03> go run .\\main.go
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan send (nil chan)]:
main.main()
        E:/project/src/go_dev/day14/demo03/main.go:6 +0x3d
exit status 2

注意点二：管道有大小，不能多取，也不能多存

//测试案例
package main

func main() {
	// chan int 我们应该把它看作一个整体，他就代表一个数据类型
	intChan := make(chan int, 3)
	intChan <- 1
	intChan <- 2
	intChan <- 3
	intChan <- 4
}


//测试结果
PS E:\\project\\src\\go_dev\\day14\\demo03> go run .\\main.go
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan send]:
main.main()
        E:/project/src/go_dev/day14/demo03/main.go:9 +0xb3
exit status 2

注意点三：管道的 遍历 与 关闭

详解：当你想遍历一个管道时，得先关闭这个管道，要不然会报错

//正确代码示例
package main

import "fmt"

func main() {
	// chan int 我们应该把它看作一个整体，他就代表一个数据类型
	intChan := make(chan int, 3)
	intChan <- 1
	intChan <- 2
	intChan <- 3
	//如果少了这句话就会报错
	close(intChan)
	for v := range intChan {
		fmt.Println(v)
	}
}

//正确结果展示
PS E:\\project\\src\\go_dev\\day14\\demo03> go run .\\main.go
1
2
3

//错误代码示例
package main

import "fmt"

func main() {
	// chan int 我们应该把它看作一个整体，他就代表一个数据类型
	intChan := make(chan int, 3)
	intChan <- 1
	intChan <- 2
	intChan <- 3
	//如果少了这句话就会报错
	// close(intChan)
	for v := range intChan {
		fmt.Println(v)
	}
}

//错误结果展示
PS E:\\project\\src\\go_dev\\day14\\demo03> go run .\\main.go
1
2
3
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
main.main()
        E:/project/src/go_dev/day14/demo03/main.go:13 +0x125
exit status 2

注意点四：管道得配合gorutine使用，编译器底层会监视管道在gorutine中的使用

详解：简单的讲就是，当你创建的管道在 gorutine 中使用之后 v := <-intChan 会成为一个阻塞方法。

//示例代码
package main

import "fmt"

func main() {
	// chan int 我们应该把它看作一个整体，他就代表一个数据类型
	intChan := make(chan int, 3)
	go func() {
		intChan <- 1
		intChan <- 2
		intChan <- 3
		close(intChan)
	}()

	v := <-intChan
	fmt.Println(v)
}

//结果展示
PS E:\\project\\src\\go_dev\\day14\\demo03> go run .\\main.go
1