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

golang chan简介(golanggc)

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

无缓冲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。

相关推荐

每天一个AI姬,AMD核显用户有福了,AI绘画打破 NVIDIA 显卡垄断

使用StableDiffusion进行AI绘画,并不一定只能使用NVIDIA英伟达显卡,甚至,也不一定只能使用独立显卡。今天我们使用AMD6800H核显,并安装了StableDif...

NETworkManager:功能强大的网络管理与问题排除工具

关于NETworkManagerNETworkManager是一款功能强大的网络管理与问题排除工具,该工具完全开源,可以帮助广大研究人员轻松管理目标网络系统并排除网络疑难问题。该工具使用远程桌面、Po...

AMD也能深度学习+免费AI绘画:StableDiffusion+ROCm部署教程!

某国政客扇扇嘴皮子,CN玩硬件和深度学习的圈子里就掀起了一场风暴,这就是著名的嘴皮子效应(误)。没了高性能计算的A100H100倒也能理解,但是美利坚这波把RTX4090禁售了就让人无语了,所以不少做...

windows 下编译 python_rtmpstream

最近在研究数字人,看了大咖的项目(https://github.com/lipku/metahuman-stream),尝试编译此项目的依赖项目python_rtmpstream(https://gi...

如何使用 Python 操作 Git 代码?GitPython 入门介绍

花下猫语:今天,我在查阅如何用Python操作Gitlab的时候,看到这篇文章,觉得还不错,特分享给大家。文中还提到了其它几种操作Git的方法,后续有机会的话,再陆续分享之~~作者:匿蟒...

网上看了不少,终于把ZlmediaKit流媒体框架搭建起来啦

你都站在2023年代了,视频通话、视频直播、视频会议、视频监控就是风口浪尖上的猪师兄,只要你学那么一丁点,拿个高薪的工作不过分吧!我也是半瓶子晃荡的,所以路人呀,共学习,同进步!本篇开始,只讲在Lin...

MacDown:一款 macOS 的强大 Markdown 编辑器

大家好,很高兴又见面了,我是"...

ZLMediaKit安装配置和推拉流

一、ZLMediaKit库简介ZLMediaKit是一个基于...

大神赞过的:学习 WebAssembly 汇编语言程序设计

文/阿里淘系F(x)Team-旭伦随着前端页面变得越来越复杂,javascript的性能问题一再被诟病。而Javascript设计时就不是为了性能优化设计的,这使得浏览器上可以运行的本地语言一...

【Docker】部署WVP视频监控平台

回来Docker系列,今天将会跟大家分享一则关于开源WVP视频监控平台的搭建。先说结论吧,一开始按照网上说的一步一步搭建没有搭建成功,不知道是版本太旧还是我这边机器有问题,尝试了好几个不同方式的搭建都...

MongoDB+GridFS存储文件方案

GridFS是MongoDB的一个内置功能,它提供一组文件操作的API以利用MongoDB存储文件,GridFS的基本原理是将文件保存在两个Collection中,一个保存文件索引,一个保存文...

【开源】强大、创新且直观的 EDA套件

今天分享的LibrePCB是...

Ollama如何制作自己的大模型?

背景Llama3发布了,这次用了...

Ollama使用指南【超全版】

一、Ollama快速入门Ollama是一个用于在本地运行大型语言模型的工具,下面将介绍如何在不同操作系统上安装和使用Ollama。官网:https://ollama.comGithub:http...

基于区块链的价值共享互联网即时通讯应用平台源码免费分享

——————关注转发之后私信回复【源码】即可免费获取到本项目所有源码基于区块链的价值共享互联网即时通讯应用平台,是一个去中心化的任何人都可以使用的通讯网络,是一款基于区块链的价值共享互联网即时通讯AP...