百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

golang chan简介(golanggc)

wptr33 2025-03-20 20:08 17 浏览

无缓冲chan

进和出都会阻塞.

有缓冲chan

先进先出队列, 出会一直阻塞到有数据, 进时当队列未满不会阻塞, 队列已满则阻塞.

select

  1. select 先遍历所有case, 所有channel表达式都会被求值、所有被发送的表达式都会被求值。求值顺序:自上而下、从左到右.
  2. 当case没有阻塞则随机执行一个没有阻塞的case就退出select
  3. 当所有case阻塞时, 则一直阻塞直到某个case解除阻塞, 但是如果有default则直接执行default
  4. 也就是一个select最多只执行一次case里的代码
  5. 要一直检测case则必须外层使用for循环包起来
  6. close(chan)
  7. close没有make的chan会引起panic
  8. close以后不能再写入,写入会出现panic
  9. close之后可以读取,无缓冲chan读取返回0值和false,有缓冲chan可以继续读取,返回的都是chan中数据和true,直到读取完所有队列中的数据,返回默认值和false
  10. 重复close会引起panic
  11. 只读chan不能close
  12. 不close chan也是可以的,当没有被引用时系统会自动垃圾回收。

只读和只写chan

read_only := make (<-chan int) write_only := make (chan<- int) 只读或者只写一般用在参数传递中。

chan和mutex

mutex的性能比chan高不少。比如开源的消息队列gnatsd(NATS)就很少用chan而使用mutex,其性能是非常高的,比另一个消息队列nsq高很多。

读写Chan

永远是符号<-进行读取或者写入,譬如v,ok := <-c是读取,而c <- v是写入。

c := make(chan int, 1)
c <- 10 // 写入chan
v := <- c // 从chan中读取

下面的例子判断chan是否关闭:

c := make(chan int, 1)
c <- 10
v,ok := <- c // 读取,v=10,ok=true
close(c)
v,ok := <- c // 读取,v=0,ok=false

如果写不进去就丢弃,可以用select:

c := make(chan int, 1)
select {
case c <- 10: // c中放入了10,因为chan的buffer为1
default: 
}
select {
case c <- 11:
default: // c中只有10,没有11
}
select {
case v,ok := <- c:
 // 读出来一个,v=10, ok=true
default:
}
select {
case v,ok := <- c:
default: // 没有可读的,走这个分支
}

超时控制

select {
 case <-timeout:
 fmt.Println("定时任务")
 case dd := <-time.After(time.Second * 3):
 fmt.Println(dd, "任务超时")
}

判断closed

读取时,如果没有ok,也是可以读取的。不过如果closed也是能读的,没有赋值而已;如果要知道是否closed得加ok,也就是除非chan永远不关闭,否则读取应该用v,ok := <-c而不是用v := <-c的方式。

c := make(chan int, 1)
c <- 10
close(c)
v := <- c // c=10,读取出来一个
v = <- c // c=0,实际上没有读出来,但是判断不了
c := make(chan int, 1)
c <- 10
close(c)
v,ok := <- c // c=10,ok=true,读取出来一个
v,ok = <- c // c=0,ok=false,实际上没有读出来

For-Range

for-range语法可以用到通道上。循环会一直接收channel里面的数据,直到channel关闭。不同于array/slice/map上的for-range,channel的for-range只允许有一个变量。

for v:=range aChannel {
 // use v
}

等价于

for {
 v, ok := <- aChannel
 if !ok {
 break
 }
 // use v
}

注意,for-range对应的channel不能是只写channel。

相关推荐

redis的八种使用场景

前言:redis是我们工作开发中,经常要打交道的,下面对redis的使用场景做总结介绍也是对redis举报的功能做梳理。缓存Redis最常见的用途是作为缓存,用于加速应用程序的响应速度。...

基于Redis的3种分布式ID生成策略

在分布式系统设计中,全局唯一ID是一个基础而关键的组件。随着业务规模扩大和系统架构向微服务演进,传统的单机自增ID已无法满足需求。高并发、高可用的分布式ID生成方案成为构建可靠分布式系统的必要条件。R...

基于OpenWrt系统路由器的模式切换与网页设计

摘要:目前商用WiFi路由器已应用到多个领域,商家通过给用户提供一个稳定免费WiFi热点达到吸引客户、提升服务的目标。传统路由器自带的Luci界面提供了工厂模式的Web界面,用户可通过该界面配置路...

这篇文章教你看明白 nginx-ingress 控制器

主机nginx一般nginx做主机反向代理(网关)有以下配置...

如何用redis实现注册中心

一句话总结使用Redis实现注册中心:服务注册...

爱可可老师24小时热门分享(2020.5.10)

No1.看自己以前写的代码是种什么体验?No2.DooM-chip!国外网友SylvainLefebvre自制的无CPU、无操作码、无指令计数器...No3.我认为CS学位可以更好,如...

Apportable:拯救程序员,IOS一秒变安卓

摘要:还在为了跨平台使用cocos2d-x吗,拯救objc程序员的奇葩来了,ApportableSDK:FreeAndroidsupportforcocos2d-iPhone。App...

JAVA实现超买超卖方案汇总,那个最适合你,一篇文章彻底讲透

以下是几种Java实现超买超卖问题的核心解决方案及代码示例,针对高并发场景下的库存扣减问题:方案一:Redis原子操作+Lua脚本(推荐)//使用Redis+Lua保证原子性publicbo...

3月26日更新 快速施法自动施法可独立设置

2016年3月26日DOTA2有一个79.6MB的更新主要是针对自动施法和快速施法的调整本来内容不多不少朋友都有自动施法和快速施法的困扰英文更新日志一些视觉BUG修复就不翻译了主要翻译自动施...

Redis 是如何提供服务的

在刚刚接触Redis的时候,最想要知道的是一个’setnameJhon’命令到达Redis服务器的时候,它是如何返回’OK’的?里面命令处理的流程如何,具体细节怎么样?你一定有问过自己...

lua _G、_VERSION使用

到这里我们已经把lua基础库中的函数介绍完了,除了函数外基础库中还有两个常量,一个是_G,另一个是_VERSION。_G是基础库本身,指向自己,这个变量很有意思,可以无限引用自己,最后得到的还是自己,...

China&#39;s top diplomat to chair third China-Pacific Island countries foreign ministers&#39; meeting

BEIJING,May21(Xinhua)--ChineseForeignMinisterWangYi,alsoamemberofthePoliticalBureau...

移动工作交流工具Lua推出Insights数据分析产品

Lua是一个适用于各种职业人士的移动交流平台,它在今天推出了一项叫做Insights的全新功能。Insights是一个数据平台,客户可以在上面实时看到员工之间的交流情况,并分析这些情况对公司发展的影响...

Redis 7新武器:用Redis Stack实现向量搜索的极限压测

当传统关系型数据库还在为向量相似度搜索的性能挣扎时,Redis7的RedisStack...

Nginx/OpenResty详解,Nginx Lua编程,重定向与内部子请求

重定向与内部子请求Nginx的rewrite指令不仅可以在Nginx内部的server、location之间进行跳转,还可以进行外部链接的重定向。通过ngx_lua模块的Lua函数除了能实现Nginx...