当前位置: 首页 > news >正文

go channel使用

go语言中有一句名言:

不要通过共享内存来通信,而应该通过通信来共享内存。

channel实现了协程间的互相通信。

目录

一、channel声明

二、向channel发送数据

三、从channel读取数据

1. i, ok := <-c

2. for i := range c(常用)

3. select监听多个channel

四、关闭channel


一、channel声明

无缓冲的channel:

c := make(chan int)

等同于:

c := make(chan int,0)

缓冲队列大小为0,元素类型为int。

阻塞发送直到有协程接收数据,阻塞接收直到有协程发送数据。

带缓冲队列的channel:

c := make(chan int,10)

声明了缓冲大小为10的channel。

二、向channel发送数据

c <- 1

向未初始化的channel(也就是nil channel)写数据,会永久阻塞;

向已关闭的channel写数据,运行会panic,panic: send on closed channel;

三、从channel读取数据

1. i, ok := <-c

ok为false时,代表channel已关闭

2. for i := range c(常用)

range读取channel,只有channel关闭后,才会退出循环

3. select监听多个channel

	go func() {loop:for {select {case i, ok := <-ch1:if !ok {break loop}fmt.Println("channel1读取到数据: ", i)}}fmt.Println("消费完毕")wg.Done()}()

读未初始化的channel(也就是nil channel)数据,会永久阻塞;

读已关闭的channel写数据,当channel中有剩余数据时,会读取剩余数据,否则,会读取元素的零值,所以需要判断ok的值,判断当前channel是否关闭,当channel关闭且channel数据读取完毕之后,ok的值为false。

四、关闭channel

close(c) 直接关闭channel

channel不在消费者侧关闭。

channel的关闭策略:

单生产者多消费者:生产者关闭

多生产者多消费者: 生产者调用sync.Once关闭,或者引入第三方的协调者,关闭channel

http://www.lryc.cn/news/41364.html

相关文章:

  • 5. QtDesignStudio中的3D场景
  • 人工智能的几个研究方向
  • 软件测试 - 常见的开发模型和测试模型
  • 从零开始的机械臂yolov5抓取gazebo仿真(四)
  • C++修炼之筑基期第一层——认识类与对象
  • IT 运营监控工具
  • java线程之Thread类的基本用法
  • 【js】多分支语句练习(2)
  • Redis与MySQL的双写一致性问题
  • Java基础:笔试题
  • spring三级缓存以及@Async产生循环引用
  • 【洛谷刷题】蓝桥杯专题突破-深度优先搜索-dfs(5)
  • 【Unity3D】Unity3D中在创建完项目后自动创建文件夹列表
  • 如何设计一个锂电池充电电路(TP4056)
  • Spark了解
  • c++STL急急急
  • 【C++学习】模板进阶——非类型模板参数 | 模板的特化 | 分离编译
  • 【C++】C++11新特性——可变参数模板|function|bind
  • ssm框架之spring:浅聊事务--JdbcTemplate
  • 盘点Python那些简单实用的第三方库
  • leetCode热题21-26 解题代码,调试代码和思路
  • ChatGPT推出第四代GPT-4!不仅能聊天,还可以图片创作!
  • 二叉搜索树:AVL平衡
  • 数据结构和算法(1):数组
  • python+django+vue全家桶鲜花商城售卖系统
  • 一文带你领略 WPA3-SAE 的 “安全感”
  • Python解题 - CSDN周赛第38期
  • Android绘制——自定义view之onLayout
  • 用Qt画一个温度计
  • Java设计模式 04-建造者模式