教程集 www.jiaochengji.com
教程集 >  Golang编程  >  golang教程  >  正文 Golang之消息机制channel

Golang之消息机制channel

发布时间:2021-05-25   编辑:jiaochengji.com
教程集为您提供Golang之消息机制channel等资源,欢迎您收藏本站,我们将为您提供最新的Golang之消息机制channel资源

1. 背景:

1. 对于以下这段代码:

按照想法应该输出 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9
但是,输出结果是: 0 1 2 3 4 5 6 7 8 9
2. 原因:
在goroutine还未来得及跑loop函数时,主函数main已经退出。
解决主函数退出太快最直接的方法是让主函数睡眠一段时间:

这次输出结果确实是两趟。
可是等待的办法并不好,因为并不知goroutine要执行多长时间,只能尽可能长的设置主函数的sleep,这样会让主函数执行时间远大于实际执行时间。
3. 需要找一个方法,让goroutine快执行完时通知主函数,即阻塞住主routine,类似Java中的A.join()函数(调用方必须等待A执行完毕返回后再返回),那么涉及多个goroutine间通信,go中的channel就起了这样的作用。

2. channel

1.定义:
channel是Golang语言在语言层级提供的goroutine间的通信方式,可以使用channel在多个goroutine之间传递消息。
2.使用:
channel是类型相关的,一个channel只能传递一种类型的值,传递类型需要在声明channel时指定。
3.声明:
1. var chanName chan ElementType
举例:声明一个传递int类型的channel:var ch chan int

2. 使用内置函数make()定义一个带缓冲的channel
ch := make(chan int, 1024)

ch := make(chan int, 1024 )
3. 单向channel的声明:
var ch2 chan <- int    // 只用于写int数据
var ch3 <-chan int    // 只用于读int数据
4. 通过类型转换将一个普通channel转换为单向:
ch4 := make(chan int)
ch5 := <-chan int(ch4)   // 单向读
ch6 := chan<- int(ch4)  //单向写
4.用法:
1. 写入:
ch <- value(将一个数据value写入channel,如果channel已满则导致阻塞,直至channel中有空闲)
2. 读取:
value := <-ch(从channel中读取数据,如果channel为空那么会导致阻塞,直至channel中有数据)

channel的发送和接收都是阻塞的。

3. 关闭不再使用的channel
close(ch)
应该在生产者的地方关闭channel,如果在消费者的地方关闭,容易引起panic;
而在一个已关闭的channel上执行读取操作总是能够立即返回,返回值是对应类型的零值。

5. 改进:
上面图中的例子可用一个信道来通知主线,当loop执行完毕,向信道中存入一个数据0,主线程开启一个goroutine后,需要从信道中读数据,那么当loop执行完毕之前,主线程一直阻塞。


到此这篇关于“Golang之消息机制channel”的文章就介绍到这了,更多文章或继续浏览下面的相关文章,希望大家以后多多支持JQ教程网!

您可能感兴趣的文章:
【文末有惊喜!】一文读懂golang channel
golang的channel机制
Golang之消息机制channel
golang知识点
Go 语言为什么这么快,带你详细了解Golang CSP并发模型
Go学习_17_Golang实现对象池
golang 订阅发布机制实现
从Deadlock报错理解Go channel机制(一)
GoLang之协程
go channel 缓冲区最大限制_Golang 入门 : channel(通道)

[关闭]
~ ~