这篇文章将为大家详细讲解有关Go语言中通道channel的示例分析，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
线程之间进行通信的时候，会因为资源的争夺而产生竟态问题,为了保证数据交换的正确性,必须使用互斥量给内存进行加锁,go语言并发的模型是CSP，提倡通过通信共享内存,而不是通过共享内存而实现通信，通道恰巧满足这种需求。
channel类似与一个队列,满足先进先出的规则,严格保证收发数据的顺序,每一个通道只能通 过固定类型的数据如果通道进行大型结构体、字符串的传输，可以将对应的指针传进去,尽量的节省空间
计算
安全
数据库
网络和加速
企业服务
//定义一个通道对象使用，其中int可以换为自己需要的类型
var a chan int
//初始化只有一个位置的通道（第一个参数代表通道类型,第二个参数代表通道有几个位置）
//位置存满后新的数据将存不进来（阻塞）
a = make(chan int,1)取出数据使用操作符 <-操作符右是输入变量,操作符左是通道代表数据流入通道内
代码如下：
// 声明一个通道
var a chan int
a <- 5取出数据也使用操作符 <-操作符右是通道,操作符左是接受变量
代码如下：
//声明一个通道类型
var a chan int
fmt.Println("未初始化的通道", a)
a = make(chan int)
// wg.Add(1)
go func(a chan int) {
// defer wg.Done()
for {
x := <-a
fmt.Println("接收到了数据：", x)
}
}(a)如果通道重复关闭或者关闭一个没有初始化的通道就会抛出错误
close(a)//a为待关闭的通道在并发函数中一次关闭通道代码如下：
// 互斥锁对象
var once sync.Once
//并发函数
//这个函数的目的是将a通道内数据乘以10发送到通道b内
func f2(a <-chan int, b chan<- int) {
defer wg.Done()
for {
x, ok := <-a
if !ok {
break
}
fmt.Println(x)
b <- x * 10
}
// 确保b通道只关闭一次
once.Do(func() {
close(b)
})
} var b <-chan int var b chan<- int示例函数：
//单项通道一般做函数参数,作为一种规范防止通道混用
//此函数完成的功能是将a内的数据乘以10放入通道b内
func f2(a <-chan int, b chan<- int) {
for {
x, ok := <-a
if !ok {
break
}
fmt.Println(x)
b <- x * 10
}
}| channel | nil未初始化 | 空通道 | 满通道 | 非空 |
|---|---|---|---|---|
| 接收 | 阻塞 | 阻塞 | 接收值 | 接收值 |
| 发送 | 阻塞 | 发送值 | 阻塞 | 发送值 |
| 关闭 | panic | 关闭成功 | 关闭成功 | 关闭成功 |
| 关闭后返回的数据 | panic | 返回0值 | 数据读完后返回零值 | 数据读完返回零值 |
注意以下情况：
在使用通道的时候,从以上表格可知有时会进入阻塞状态,结合waitGroup,如果在主函数等待使用通道的函数执行结束,而使用通道的函数并且通道陷入阻塞状态,如果有其他函数对其进行唤醒则不会死锁,如果没有其他函数可以对其进行唤醒则会抛出死锁异常。
关于“Go语言中通道channel的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
