这是我参与更文挑战的第 13 天，活动详情查看：更文挑战

GO通道和 sync 包的分享

我们一起回顾一下上次分享的内容：

GO协程同步若不做限制的话，会产生数据竞态的问题
我们用锁的方式来解决如上问题，根据使用场景选择使用互斥锁和读写锁
比使用锁更好的方式是原子操作，但是使用go的 sync/atomic需要小心使用，因为涉及内存

要是对GO的锁和原子操作还感兴趣的话，欢迎查看文章GO的锁和原子操作分享

上次我们分享到锁和原子操作，都可以保证共享数据的读写

可是，他们还是会影响性能，不过，Go 为开发这提供了通道这个神器

今天我们来分享一下Go中推荐使用的其他同步方法，通道和 sync 包

通道是什么？

是一种特殊的类型，是连接并发goroutine的管道

channel 通道是可以让一个 goroutine 协程发送特定值到另一个 goroutine 协程的通信机制。

通道像一个传送带或者队列，总是遵循先入先出（First In First Out）的规则，保证收发数据的顺序，这一点和管道是一样的

一个协程从通道的一头放入数据，另一个协程从通道的另一头读出数据

每一个通道都是一个具体类型的导管，声明 channel 的时候需要为其指定元素类型。

通道能做什么？

控制协程的同步，让程序有序运行

GO 中提倡 不要通过共享内存来通信，而通过通信来共享内存

goroutine协程是 Go 程序并发的执行体，channel 通道就是它们之间的连接，他们之间的桥梁，他们的交通枢纽

通道有哪几种？

大致可分为如下三种：

无缓冲通道
有缓冲的通道
单向通道

无缓冲通道

无缓冲的通道又称为阻塞的通道

无缓冲通道上的发送操作会阻塞，直到另一个goroutine在该通道上执行接收操作，这时值才能发送成功

两个 goroutine 协程将继续执行

我们反过来看，如果接收操作先执行，接收方的goroutine将阻塞，直到另一个 goroutine 协程在该通道上发送一个数据

因此，无缓冲通道也被称为同步通道，因为我们可以使用无缓冲通道进行通信，利用发送和接收的 goroutine 协程同步化

有缓冲的通道

还是上述提到的，有缓冲通道，就是在初始化 / 创建通道的 make 函数的第 2 个参数填上我们所期望的缓冲区大小，例如：

ch1 := make(chan int , 4)
复制代码

此时，该通道的容量为4，发送方可以一直向通道中发送数据，直到通道满，且通道数据未被读走时，发送方就会阻塞

只要通道的容量大于零，那么该通道就是有缓冲的通道

通道的容量表示通道中能存放元素的数量

我们可以使用内置的 len函数 获取通道内元素的数量，使用 cap函数 获取通道的容量

单向通道

通道默认是既可以读有可以写的，但是单向通道就是要么只能读，要么只能写

chan <- int

是一个只能发送的通道，可以发送但是不能接收

<- chan int

是一个只能接收的通道，可以接收但是不能发送

如何创建和声明一个通道

声明通道

在 Go 里面，channel是一种类型，默认就是一种引用类型

简单解释一下什么是引用：

在我们写C++的时候，用到引用会比较多

引用，顾名思义是某一个变量或对象的别名，对引用的操作与对其所绑定的变量或对象的操作完全等价

在C++里面是这样用的：

类型 &引用名=目标变量名；

声明一个通道

var 变量名 chan 元素类型

var ch1 chan string   			// 声明一个传递字符串数据的通道
var ch2 chan []int 				// 声明一个传递int切片数据的通道
var ch3 chan bool  				// 声明一个传递布尔型数据的通道
var ch4 chan interface{}  		// 声明一个传递接口类型数据的通道
复制代码

看，声明一个通道就是这么简单

对于通道来说，关声明了还不能使用，声明的通道默认是其对应类型的零值，例如

int 类型零值就是 0
string 类型零值就是个空串
bool 类型零值就是 false
切片的零值就是 nil

我们还需要对通道进行初始化才可以正常使用通道哦

初始化通道

一般是使用 make 函数初始化之后才能使用通道，也可以直接使用make函数 创建通道

例如：

ch5 := make(chan string)
ch6 := make(chan []int)
ch7 := make(chan bool)
ch8 := make(chan interface{})
复制代码

make 函数的第二个参数是可以设置缓冲的大小的，我们来看看源码的说明

// The make built-in function allocates and initializes an object of type
// slice, map, or chan (only). Like new, the first argument is a type, not a
// value. Unlike new, make's return type is the same as the type of its
// argument, not a pointer to it. The specification of the result depends on
// the type:
// Slice: The size specifies the length. The capacity of the slice is
// equal to its length. A second integer argument may be provided to
// specify a different capacity; it must be no smaller than the
// length. For example, make([]int, 0, 10) allocates an underlying array
// of size 10 and returns a slice of length 0 and capacity 10 that is
// backed by this underlying array.
// Map: An empty map is allocated with enough space to hold the
// specified number of elements. The size may be omitted, in which case
// a small starting size is allocated.
// Channel: The channel's buffer is initialized with the specified
// buffer capacity. If zero, or the size is omitted, the channel is
// unbuffered.
func make(t Type, size ...IntegerType) Type
复制代码

如果 make 函数的第二个参数不填，那么就默认是无缓冲的通道

现在我们来看看如何操作 channel 通道，都可以怎么玩

如何操作 channel

通道的操作有如下三种操作：

发送（send）
接收(receive）
关闭（close）

对于发送和接收通道里面的数据，写法就比较形象，使用 <- 来指向是从通道里面读取数据，还是从通道中发送数据

向通道发送数据

// 创建一个通道
ch := make(chan int)
// 发送数据给通道
ch <- 1
复制代码

我们看到箭头的方向是，1 指向了 ch 通道，所以不难理解，这是将1 这个数据，放入通道中

从通道中接收数据

num := <-ch
复制代码

不难看出，上述代码是 ch 指向了一个需要初始化的变量，也就是说，从 ch 中读出一个数据，赋值给 num

我们从通道中读出数据，也可以不进行赋值，直接忽略也是可以的，如：

<-ch
复制代码

关闭通道

Go中提供了 close 函数来关闭通道

close(ch)
复制代码

对于关闭通道非常需要注意，用不好直接导致程序崩溃

只有在通知接收方 goroutine 协程所有的数据都发送完毕的时候才需要关闭通道
通道是可以被垃圾回收机制回收的，它和关闭文件是不一样的，在结束操作之后关闭文件是必须要做的，但关闭通道不是必须的

关闭后的通道有以下 4 个特点：

对一个关闭的通道再发送值就会导致 panic
对一个关闭的通道进行接收会一直获取值直到通道为空
对一个关闭的并且没有值的通道执行接收操作会得到对应类型的零值
关闭一个已经关闭的通道会导致 panic

通道异常情况梳理

我们来整理一下对于通道会存在的异常：

channel 状态	未初始化的通道（nil）	通道非空	通道是空的	通道满了	通道未满
接收数据	`阻塞`	接收数据	`阻塞`	接收数据	接收数据
发送数据	`阻塞`	发送数据	发送数据	`阻塞`	发送数据
关闭	panic	关闭通道成功待数据读取完毕后返回零值	关闭通道成功直接返回零值	关闭通道成功待数据读取完毕后返回零值	关闭通道成功待数据读取完毕后返回零值

每一种通道的DEMO实战

无缓冲通道

func main() {
   // 创建一个无缓冲的，数据类型 为 int 类型的通道
   ch := make(chan int)
   // 向通道中写入 数字 1
   ch <- 1
   fmt.Println("send successfully ... ")
}
复制代码

执行上述代码我们可以查看到效果

fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan send]:
main.main()
        F:/my_channel/main.go:9 +0x45
exit status 2
复制代码

出现上述报错 deadlock 错误的原因，细心的小伙伴应该能够知道为什么，我上述有提到

我们使用 ch := make(chan int) 创建的是无缓冲的通道

无缓冲的通道只有在有接收方接收值的时候才能发送数据成功

我们可以想一下我们生活中的案例一样：

你在某东上买了一个稍微贵重一点的物品，某东快递人员给你寄快递的时候，打电话给你，必须要送到你的手上，不然不敢签收，这个时候，你不方便，或者你不签收，那么这个快递就是算作没有寄送成功

因此，上述问题原因是，创建了一个无缓冲通道，发送方一直在阻塞，通道中一直未有协程读取数据，导致死锁

我们的解决办法就是创建另外一个协程，将数据从通道中读出来即可

package main

import "fmt"

func recvData(c chan int) {
	ret := <-c
	fmt.Println("recvData successfully ... data = ", ret)
}

func main() {
	// 创建一个无缓冲的，数据类型 为 int 类型的通道
	ch := make(chan int)
	go recvData(ch)
	// 向通道中写入 数字 1
	ch <- 1
	fmt.Println("send successfully ... ")
}
复制代码

这里需要注意，如果 go recvData(ch) 放在了 ch <- 1 之后，那么结果还是一样的死锁，原因还是因为 ch <- 1 会一直阻塞，根本不会执行到他之后的语句

实际效果

recvData successfully ... data =  1
send successfully ...
复制代码

有缓冲通道

func main() {
   // 创建一个无缓冲的，数据类型 为 int 类型的通道
   ch := make(chan int , 1)
   // 向通道中写入 数字 1
   ch <- 1
   fmt.Println("send successfully ... ")
}
复制代码