个人中心
文章发布
退出
作者热门文章
- Java锁的逻辑（结合对象头和ObjectMonitor）
- 还在用饼状图？来瞧瞧这些炫酷的百分比可视化新图形（附代码实现）⛵
- 自动注册实体类到EntityFrameworkCore上下文，并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
24
4
转载请注明出处:
在多个协程之间进行通信和管理，可以使用 Go 语言提供的通道（Channel）类型。通道是一种特殊的数据结构，可以在协程之间进行传递数据，从而实现协程之间的通信和同步。多个协程可以同时读写同一个通道，通过通道来进行数据的传递和共享.
通道遵循先入先出(First In First Out)的原则，保证收发数据的顺序。通道是一个特殊的数据类型，在使用之前必须定义和创建通道变量，定义通道的语法如下:
var
name
chan
type
语法格式说明如下:
1）var是Go语言关键字，用于定义变量.
2）name是通道变量名称，可自行命名.
3）chan是Go语言关键字，将变量定义为通道类型.
4）type是通道存放的数据类型.
通道定义之后，还需要使用关键字make创建通道，通道的创建语法如下:
name :=
make
(
chan
type
, num)
语法格式说明如下:
1）name是通道变量名称，可自行命名.
2）make是Go语言关键字，用于创建通道.
3）chan type的chan是Go语言关键字，type是通道能存放的数据类型.
4）num是通道存放数据的数量上限.
在实际编程中，我们直接使用关键字make创建通道即可使用，这样能省去定义通道的过程，示例代码如下:
//
定义和创建通道
var
ch
chan
string
ch
=
make
(
chan
string
)
//
直接创建通道，无须定义
ch :=
make
(
chan
string
)
通道创建之后，使用通道完成写入和读取数据操作。在通道里面写入和读取数据需要由<-操作符实现，使用说明如下:
//
构建通道
ch :=
make
(
chan
string
)
//
往通道写入数据
ch <-
"
Hello
"
//
从通道获取数据，赋予变量s
s := <- ch
。
无缓冲通道是 Go 语言中一种常见的通道类型，也称为同步通道或阻塞通道。无缓冲通道的特点是在发送和接收数据时，必须有另外一个协程同时进行相反的操作，否则会阻塞当前协程。 具体来说，无缓冲通道的特点如下:
发送和接收操作是同步的，即发送操作必须等待接收操作完成后才能继续执行，接收操作也必须等待发送操作完成后才能继续执行.
无缓冲通道的容量为 0，即只有在发送和接收操作同时进行时才能传递数据，否则会阻塞当前协程.
无缓冲通道的数据传递是按照先进先出的顺序进行的，即发送的数据会按照发送的顺序被接收。 无缓冲通道可以用于协程之间的同步和通信，例如在生产者和消费者模式中，可以使用无缓冲通道来传递数据，从而保证生产者和消费者之间的同步和互斥。同时，无缓冲通道的使用也可以避免数据竞争问题，从而提高程序的安全性和可靠性.
通道是通过关键字make创建的，在创建过程中，如果没有设置参数num，则视为创建无缓冲通道。无缓冲通道(Unbuffered Channel)是指在获取数据之前没有能力保存数据的通道，这种类型的通道要求两个Goroutine同时处于执行状态才能完成写入和获取操作.
如果两个Goroutine没有同时准备，某一个Goroutine执行写入或获取操作将会处于阻塞等待状态，另一个Goroutine无法执行写入或获取操作，程序将会提示异常，这种类型的通道执行写入和获取的交互行为是同步，任意一个操作都无法离开另一个操作单独存在.
当我们使用无缓冲通道的时候，必须注意通道变量的操作，确保程序中有两个或两个以上的Goroutine同时执行通道的读写操作，读写操作必须是一读一写，不能只读不写或只写不读，示例如下:
//
只写入数据，不读取
ch :=
make
(
chan
string
)
ch
<-
"
Tom
"
fmt.Println(
"
wait goroutine
"
)
//
只读取数据，不写入
ch :=
make
(
chan
string
)
<-
ch
fmt.Println(
"
wait goroutine
"
)
通道数据只写入不读取或者只读取不写入都会提示fatal error: all goroutines are asleep–deadlock异常，如果需要实现通道数据获取超时检测，可以使用关键字select实现.
如果程序中仅有一个Goroutine，使用通道读写数据也会导致异常，比如在主函数main()中对通道写入数据，再读取通道数据，示例如下:
package
main
import
(
"
fmt
"
)
func
main() {
//
构建通道
ch :=
make
(
chan
string
)
//
写入通道数据
ch <-
"
Tom
"
//
读取通道数据
<-
ch
fmt.Println(
"
wait goroutine
"
)
}
如果在发送和接收数据时出现异常，则会引发程序异常。例如，如果我们在发送数据之前关闭通道，则会引发一个运行时异常。为了避免这种情况的发生，我们可以使用 defer 语句在函数退出之前关闭通道。例如:
func
main() {
ch :
=
make
(
chan
int
)
defer
close
(ch)
//
使用 defer 关闭通道
go
func
() {
fmt.Println(
"
开始发送消息...
"
)
ch
<-
1
fmt.Println(
"
消息发送完成。
"
)
}()
fmt.Println(
"
开始接收消息...
"
)
msg :
= <-
ch
fmt.Printf(
"
接收到的消息是：%d\n
"
, msg)
fmt.Println(
"
消息接收完成。
"
)
}
带缓冲通道(Buffered Channel)是在被获取前能存储一个或者多个数据的通道，这种类型的通道并不强制要求Goroutine之间必须同时完成写入和获取。当通道中没有数据的时候，获取动作才会阻塞；当通道没有可用缓冲区存储数据的时候，写入动作才会阻塞.
在无缓冲通道的基础上，只要为通道增加一个有限大小的存储空间就能形成带缓冲通道。带缓冲通道在写入时无须等待获取即可再次执行下一轮写入，并且不会发生阻塞，只有当存储空间满了才会发生阻塞。同理，如果带缓冲通道中有数据，获取时将不会发生阻塞，直到通道中没有数据可读时，通道才会阻塞.
从通道的定义角度分析，带缓冲和无缓冲通道的区别在于参数num。创建通道的时候，如果没有设置参数num，则默认参数值为0，通道为无缓冲通道，所以写入和获取数据必须同时进行才不会因阻塞而异常；如果参数num大于0，则写入和获取数据无须同步执行，因为通道有足够的空间存放数据.
由于带缓冲通道没有读写同步限制，我们可以在同一个Goroutine中执行多次写入和获取操作，具体示例如下:
package
main
import
"
fmt
"
func
main() {
//
创建一个3个元素缓冲大小的整型通道
ch :=
make
(
chan
int
,
3
)
//
查看当前通道的大小
fmt.Println(
len
(ch))
//
发送3个整型元素到通道
for
i :=
0
; i <
3
; i++
{
ch
<-
i
}
//
查看当前通道的大小
fmt.Println(
len
(ch))
for
i :=
0
; i <
3
; i++
{
fmt.Println(
<-
ch)
}
//
查看当前通道的大小
fmt.Println(
len
(ch))
//
查看当前通道的容量
fmt.Println(
cap
(ch))
}
上述代码的说明如下:
1）通过for执行了3次循环，每次循环将变量i写入通道，然后通过3次循环从通道获取数据并输出.
2）通道写入和读取数据的时候，使用len()函数获取通道已有的数据量，判断当前通道存储的数据量是否达到上限，这样可以防止程序在运行时提示异常.
3）使用cap()函数能获取通道的容量大小，即获取创建通道make()的参数num的大小。带缓冲通道在很多特性上和无缓冲通道类似，无缓冲通道可以看作长度为0的带缓冲通道.
根据这个特性，带缓冲通道在下列情况下会发生阻塞:
1）带缓冲通道的存储数据达到上限时，再次写入数据将发生阻塞而导致异常.
2）带缓冲通道没有存储数据时，获取数据将发生阻塞而导致异常.
Go语言为什么对通道要限制长度？因为多个Goroutine之间使用通道必然存在写入和获取操作，这种模式类型的典型例子为生产者消费者模式。如果不限制通道长度，当写入数据速度大于获取速度，内存将不断膨胀直到应用崩溃。因此，限制通道的长度有利于约束数据生产速度，生产数据量必须在数据消费速度+通道长度的范围内，这样才能正常地处理数据.
。
。
最后此篇关于GO通道：无缓冲通道与缓冲通道的文章就讲到这里了,如果你想了解更多关于GO通道：无缓冲通道与缓冲通道的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
24
4
0
我正在使用 MediaPlayer 在我的应用程序中播放在线 mp3 文件中的一些声音。 但是，即使在播放完成后，我也会在控制台中收到一行又一行的回调和缓冲。 10-24 08:08:48.467
我有一个简单的多边形。 dfr p = st_polygon(list(as.matrix(dfr))) > pbuf = st_buffer(p, .4) > plot(pbuf) > plot(
这可能又是一些愚蠢的问题，也许这确实是我所缺少的东西，但我很难让 glMultiDrawArrays 在 OpenGL4 中工作。 我发现了很多这样的解释: for (int i = 0; i #i
这仅仅是根据网络速度调整预缓冲内容量的问题吗？你是否在一开始就为此调整一次，每秒......？ 或者它更复杂 - 对您的网络速度记录历史进行采样并取平均值/中值并对其进行调整？ 最佳答案 您的第二段总
嗨，我正在使用 FFmpeg Autogen C#。当我使用 mkv 输出作为文件并使用 h264 rtsp 流作为输入时，一切正常。编解码器是 libx264 ffmpeg.avio_open(
我需要多次遍历几个文本文件的行。目前这是通过多个 with open("file.txt") as f: for line in f: # do something 虽然性能还
昨天给同学们写了一个xinetd小练习:做一个反向回显程序。 为了学习新东西，我尝试实现一个 Haskell 解决方案。琐碎的main = forever $ interact reverse不起作用
我正在阅读《实时渲染第三版》中的遮挡剔除部分，但我无法理解它是如何工作的。一些问题: “Z 金字塔”有何贡献？为什么我们需要多种分辨率的 Z 缓冲区？在书中，它的显示如下(左侧): 八叉树结构与用于一
我通过串行端口与设备通信。 我已成功获取 InputStream 并读取设备发送的内容。 但问题是，我根本不知道何时停止阅读并继续执行另一项任务。 这是简化的代码: inputStream = ser
我有以下代码: func (q *Queue) GetStreams(qi *QueueInfo) { channel := make(chan error, len(qi.AudioChun
在我调用 -play 之前，有没有办法让 MPMusicPlayerController 缓冲内容？还是在您设置队列时默认执行此操作？ AVAudioPlayer 有 -prepareToPlay 方
我正在编写一个数据库 备份函数，从System.Diagnostics.Process 对象 读取StandardOutput (StreamReader) 属性。我已成功写入普通文件。 //This
我有一个 wpf 应用程序，其中所有 viewModel 都继承自实现 INotifyPropertyChanged 的类 NotifyPropertyChangeClass(见下文)。 我想限制
我需要类似于 withLatestFrom 的东西，对应于下图: ---------A-----------------B-- -1-2-3------4------5-6-7-8---- -----
有没有办法缓冲 OutputStream，在返回之前修改它？这是我的代码片段: public ServletOutputStream getOutputStream() throws IOExcept
目前我们有实现服务器通信协议(protocol)缓冲的需求。如果有人对此有任何意见，他们可以向我提供任何意见吗。 最佳答案 请查看以下 Protocol Buffer 链接。 http://code.
所以我目前正在开发一个 Java 应用程序，该应用程序应该将特定事件记录到数据库中。我希望每分钟最多有 15 到 20 次插入，基本上我想知道我是否应该为每个插入语句建立一个新连接，或者只要应用程序正
请考虑以下代码，包括两个线程 buffering_thread(用一条消息填充缓冲区指针)和 sending_thread(清空缓冲区): #include "msg.cpp" msg * buffe
是否可以在线播放由两个或多个视频文件组成的视频？ 由于我原来的帖子不够清楚，这里有扩展的解释和问题。 我的站点托管在 Linux/Apache/PHP 服务器上。我有 FLV/F4V 格式的视频文件。
这是我用于缓冲和转换传入事件的代码: public Publisher> logs(String eventId) { ConnectableObservable connectableObs
我是一名优秀的程序员,十分优秀！