linux消息队列go的channel,浅谈Go Channel 高级实践
channel 是 golang 里相当有趣的一个功能,在我使用 golang 编码的经验里,大部分事件都会是在享受 channel 和 goroutine 配合的乐趣。所以本文主要介绍 channel 的一些有趣的用法。
这里有 Oling Cat 翻译的Go编程语言规范里关于 channel(信道)的描述:
信道提供了一种机制,它在两个并发执行的函数之间进行同步,并通过传递(与该信道元素类型相符的)值来进行通信。
这个个描述又乏味、又枯燥。在我第一次阅读的时候,完全不明白这到底是个什么玩意。事实上,可以认为 channel 是一个管道或者先进先出队列,非常简单且轻量。channel 并不是 Golang 首创的。它同样作为内置功能出现在其他语言中。在大多数情况下,它是一个又大、又笨、又复杂的消息队列系统的一个功能。
本文主要讲实践,原理部分会一笔带过,关于 go 语言并发实现和内存模型后续会有文章。
channel 是干什么的
意义:channel 是用来通信的
实际上:(数据拷贝了一份,并通过 channel 传递,本质就是个队列)
channel 应该用在什么地方
核心:需要通信的地方
例如以下场景:
通知广播
交换数据
显式同步
并发控制
...
记住!channel 不是用来实现锁机制的,虽然有些地方可以用它来实现类似读写锁,保护临界区的功能,但不要这么用!
channel 用例实现
超时控制
// 利用 time.After 实现
func main() {
done := do()
select {
case
// logic
case
// timeout
}
}
func do()
done := make(chan struct{})
go func() {
// do something
// ...
done
}()
return done
}
取最快的结果
比较常见的一个场景是重试,第一个请求在指定超时时间内没有返回结果,这时重试第二次,取两次中最快返回的结果使用。
超时控制在上面有,下面代码部分就简单实现调用多次了。
func main() {
ret := make(chan string, 3)
for i := 0; i < cap(ret); i++ {
go call(ret)
}
fmt.Println(
}
func call(ret chan
// do something
// ...
ret
}
限制最大并发数
// 最大并发数为 2
limits := make(chan struct{}, 2)
for i := 0; i < 10; i++ {
go func() {
// 缓冲区满了就会阻塞在这
limits
do()
}()
}
for...range 优先
for ... range c { do } 这种写法相当于 if _, ok :=
func main() {
c := make(chan int, 20)
go func() {
for i := 0; i < 10; i++ {
c
}
close(c)
}()
// 当 c 被关闭后,取完里面的元素就会跳出循环
for x := range c {
fmt.Println(x)
}
}
多个 goroutine 同步响应
利用 close 广播
func main() {
c := make(chan struct{})
for i := 0; i < 5; i++ {
go do(c)
}
close(c)
}
func do(c
// 会阻塞直到收到 close
fmt.Println("hello")
}
非阻塞的 select
select 本身是阻塞的,当所有分支都不满足就会一直阻塞,如果想不阻塞,那么一个什么都不干的 default 分支是最好的选择
select {
case
return
default:
}
for{select{}} 终止
尽量不要用 break label 形式,而是把终止循环的条件放到 for 条件里来实现
for ok {
select {
case ch
case
ok = false
}
}
channel 特性
基础特性
操作
值为 nil 的 channel
被关闭的 channel
正常的 channel
close
panic
panic
成功关闭
c
永远阻塞
panic
阻塞或成功发送
永远阻塞
永远不阻塞
阻塞或成功接收
happens-before 特性
无缓冲时,接收 happens-before 发送
任何情况下,发送 happens-before 接收
close happens-before 接收
参考
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
linux消息队列go的channel,浅谈Go Channel 高级实践相关推荐
- linux消息队列非亲缘,linux进程
linux进程Tag内容描述: 1.linux消息队列进程通信 一.消息队列的基本概念消息队列(也叫做报文队列)是Unix系统V版本中3种进程间通信机制之一.另外两种是信号灯和共享内存.这些IPC机制 ...
- linux.调整收发队列,linux消息队列通信
程序目的:学习linux消息队列通信 所用主要函数:msgget(),msgsnd(),msgrcv(),msgctl() 首先介绍每个函数的用法: (1)msgget 使用格式: #include ...
- linux 消息队列 msgget/msgsnd/msgrecv
专栏内容:linux下并发编程 个人主页:我的主页 座右铭:天行健,君子以自强不息:地势坤,君子以厚德载物. 目录 前言 概述 原理 消息队列的大小 查看资源 接口 代码演示 结尾 前言 本专栏主要分 ...
- php 阻塞消息队列,linux 消息队列阻塞
php 使用socket告知Python,可以在socket上声明是及时推送还是延迟推送######哦?愿闻其详 那要是很多用户同时并发呢######system 调用外部程序是一种办法######@ ...
- linux 易语言窗口程序_浅谈Linux入门的基本知识
浅谈Linux入门的基本知识 图形模式与文字模式的切换方式Linux预设提供了六个命令窗口终端机让我们来登录. 默认我们登录的就是第一个窗口,也就是tty1,这个六个窗口分别为tty1.tty2 - ...
- PHP下操作Linux消息队列完成进程间通信的方法
2019独角兽企业重金招聘Python工程师标准>>> 来源:http://www.jb51.net/article/24353.htm 关于Linux系统进程通信的概念及实现可查看 ...
- [Linux]消息队列
我们知道进程间通信的方法有多种,主要有管道,消息队列,信号量,共享内存,socket等.之前介绍过管道,今天再介绍一个新的概念–消息队列. 消息队列:将一个进程到另一个进程之间发送数据块的方式.这些发 ...
- linux 消息队列机制
现在我们来讨论第三种也是最后一种System V IPV工具:消息队列.在许多方面看来,消息队列类似于有名管道,但是却没有与打开与关闭管道的复杂关联.然而,使用消息队列并没有解决我们使用有名管道所遇到 ...
- linux消息队列的内核限制
[from:http://blog.csdn.net/cwj649956781/article/details/8804908] 消息队列: 1.每次msgrcv一个消息,1.那个消息会在内核中移除 ...
最新文章
- IIS6.0限制上传文件大小的解决办法
- 初步理解Java的三大特性——封装、继承和多态
- 基础笔记6(exception)
- 计算机系统基础期中考试,计算机系统基础第二次作业.docx
- python取的键不存在_Python3基础 dict get 在查询不存在的键时,返回指定的内容
- 使用TargetSources
- 基于skitter的轮播图炫酷效果,幻灯片的体验
- datagrid设置单元格边框_更改 DataGridView 控件中的边框和网格线样式 - Windows Forms .NET Framework | Microsoft Docs...
- WAN killer
- Python 开发音乐下载器实践
- 小米蓝牙耳机持续白灯_小米蓝牙耳机不能自动串联问题
- 多种Map简单使用和测试
- Regular Expression简介
- JS 如何清除页面缓存
- 扫地机器人水箱背景_一种扫地机器人的水箱结构的制作方法
- 跑步感到痛苦,试试超慢跑
- java触发器linux,Auto activation triggers for Java(代码提示)功能扩展
- QUIC协议原理详解
- 带你认识 flask 国际化和本地化
- 本地k8s集群搭建保姆级教程(4)-安装k8s集群Dashboard
热门文章
- 适用于Wonderware的TOP Server的虚拟化操作
- 三个路由器的静态路由设置
- Android 手机中国移动网络接入点设置
- FBI针对Tor网络的恶意代码分析
- 利用libwebsockets写ws、wss服务端和客户端
- 熊猫阿波的故事及C++保留小数点的问题
- Mysql不能备份序列_无法mysqldump
- 【洛谷】P1318 积水面积
- 第四章 指令集体系结构——广度和深度
- 论文《FLAME:Feature-Likeilhood Based Mapping and Localization for Autonomous Vehicles》阅读总结