实现多goroutine之间的发布和订阅

实现多goroutine之间的发布和订阅

一、实现思路

  • 一个发布者,三个订阅者
  • 发布者需要跟每个订阅者之间,都要建立一个chan
  • 调用发布方法后,三个订阅者都能收到发布的信息
  • 在发布和接收之间,增加暂停,使运行结果更加直观

二、实现代码

func Test_Main(t *testing.T) {sl := NewSubList()// 增加A的订阅sl.Subscribe("A", make(Broadcast))// 增加B的订阅sl.Subscribe("B", make(Broadcast))// 增加C的订阅sl.Subscribe("C", make(Broadcast))Sleep(3)sl.PublishMessage("Hello World!")Sleep(3)sl.PublishMessage("Golang very good!")sl.Unsubscribe("B")Sleep(3)sl.PublishMessage("Golang so easy!")
}type Broadcast chan stringtype SubList struct {CH map[string]Broadcastsync.RWMutex
}func NewSubList() *SubList {s := &SubList{}s.CH = make(map[string]Broadcast) //所有channelreturn s
}// Subscribe 订阅
func (s *SubList) Subscribe(name string, bc Broadcast) {s.Lock()s.CH[name] = bcs.Unlock()go s.ListeningBroadcast(name, bc)
}// Unsubscribe 取消订阅
func (s *SubList) Unsubscribe(name string) {s.Lock()delete(s.CH, name)s.Unlock()
}//发布消息
func (s *SubList) PublishMessage(message string) {s.RLock()for k, v := range s.CH {v <- messagefmt.Println("向 ", k, " 发送 ", message)}s.RUnlock()
}// ListeningBroadcast 监听信息
func (s *SubList) ListeningBroadcast(name string, bc Broadcast) {for {message := <-bctime.Sleep(time.Duration(1) * time.Second)fmt.Println(name, " 收到 ", message)}
}func Sleep(i int64)  {fmt.Println("等待3秒……")time.Sleep(time.Duration(i) * time.Second)
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/877503.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CSS使用touch-action属性控制设备的触摸行为

touch-action CSS 属性是一个用于设置触摸操作&#xff08;如触摸滑动、双击缩放等&#xff09;在特定元素上的默认行为如何被浏览器处理的属性。这个属性主要用于优化移动端和触摸设备的交互体验&#xff0c;减少不必要的触摸事件处理或冲突&#xff0c;特别是在处理滚动、缩放…

C语言-部分字符串函数详解 1-4

C语言-部分字符串函数详解 1-4 前言1.strlen1.1基本用法1.2注意事项\0size_t 1.3模拟实现 2.strcpy2.1基本用法2.2注意事项**源字符串必须以 \0 结束****会将源字符串中的 \0拷贝到目标空间****目标空间必须可修改****目标空间必须能容纳下源字符串的内容** 2.3模拟实现 3.strn…

【深度学习】【语音TTS】GPT-SoVITS v2 实战,训练一个人的音色,Docker镜像

文章目录 原理Dockerdocker push训练教程: https://www.yuque.com/baicaigongchang1145haoyuangong/ib3g1e/xyyqrfwiu3e2bgyk 原理 Docker 不用docker不行,不好分配显卡, 做个docker镜像: docker pull pytorch/pytorch:2.1.2

windows 本地安装 Llama3.1 记录

1. 参考博客&#xff1a;1. 只要8G显卡&#xff01;本地运行最强Llama 3.1大模型&#xff01;&#xff1a;https://zhuanlan.zhihu.com/p/711409433 2. 只要8G显卡&#xff01;本地运行最强Llama 3.1大模型&#xff01;&#xff1a;https:/…

接口基础知识9:详解response body(响应体)

课程大纲 一、定义 HTTP响应体&#xff08;HTTP Response Body&#xff09;&#xff1a;服务器返回给客户端的数据部分&#xff0c;‌它包含了服务器对客户端请求的响应内容&#xff08;如客户端请求的资源、客户端请求的执行结果&#xff09;。 与请求类似&#xff0c;HTTP …

vue中父组件向子组件传值,子组件向父组件传值,简洁易懂

Vue中父组件传值到子组件 Vue中父组件传值分为两步&#xff1a; 一、父组件中代码中&#xff0c;使用属性绑定向子组件传递数据&#xff0c; 如图, 其中&#xff0c;:titles"title"就是在将父组件的title属性值&#xff0c;传递到子组件所绑定的titles属性中&#x…

python之matplotlib (3 坐标轴设置)

写在前面 在说明坐标轴设置之前&#xff0c;我有必要和大家说清楚图像设置的一些方法&#xff0c;避免陷入困扰模糊的地步。前面我们说过&#xff0c;画图的三种方法&#xff08;python之matplotlib &#xff08;1 介绍及基本用法&#xff09;-CSDN博客&#xff09;。而设置也…

2024开源资产管理系统推荐 8款免费开源IT资产管理系统/软件

开源资产管理系统 开源资产管理系统是帮助企业管理、跟踪和优化其资产的强大工具。这些系统能够自动记录资产的详细信息&#xff0c;如采购日期、使用情况、维护记录等&#xff0c;从而实现资产的全生命周期管理。企业可以通过这些系统优化资产使用效率&#xff0c;减少资产闲…

【TCP】确认应答、超时重传机制和TCP报头

TCP 相关机制 TCP 基本特点&#xff1a;有连接、可靠传输、面向字节流、全双工 有连接、面向字节流和全双工都能在前面的代码中体现有连接&#xff1a;必须要先调用 accept 建立联系才能处理面向字节流&#xff1a;会拿到 clientSocket 对象的 InputStream 和 OutputStream&a…

轻松解决找不到“MSVCP120.dll”的困扰

文章目录 轻松解决找不到“MSVCP120.dll”的困扰了解“MSVCP120.dll”可能导致问题的原因解决方法方法一&#xff1a;重新安装 Microsoft Visual C Redistributable 包&#xff08;亲测有效&#xff09;附官方网站链接两个安装包链接方法二&#xff1a;使用系统文件检查工具&am…

python人工智能002:jupyter基本使用

小知识&#xff1a;将jupyter修改为中文&#xff0c;修改用户变量&#xff0c; 注意是用户变量&#xff0c;不是系统变量 新增用户变量 变量名&#xff1a;LANG 变量值&#xff1a;zh_CN.UTF8 然后重启jupyter 上一章的软件安装完成之后&#xff0c;就可以创建文件夹来学习写…

Redis中List数据类型常用命令

目录 1. 基本操作 &#xff08;1&#xff09;在列表的头部插入一个元素 &#xff08;2&#xff09;在列表的尾部插入一个元素 &#xff08;3&#xff09;获取列表的长度 &#xff08;4&#xff09;获取列表中的元素 2. 读取和修改 &#xff08;1&#xff09;获取列表的范围&…

MaxKB(二):Ubuntu24.04搭建maxkb开发环境

接上文&#xff1a;windows10搭建maxkb开发环境&#xff08;劝退指南&#xff09; 上文在windows10环境搭建maxkb开发环境遇到各种坑&#xff0c;后面就转战ubuntu平台&#xff0c;果然比较顺利的完成开发环境搭建。当然遇到相关的问题还是可以参考上文《windows10搭建maxkb开发…

拟合与插值|线性最小二乘拟合|非线性最小二乘拟合|一维插值|二维插值

挖掘数据背后的规律是数学建模的重要任务&#xff0c;拟合与插值是常用的分析方法 掌握拟合与插值的基本概念和方法熟悉Matlab相关程序实现能够从数据中挖掘数学规律 拟合问题的基本提法 拟合问题的概念 已知一组数据(以二维为例)&#xff0c;即平面上n个点 ( x i , y i ) …

Harbor仓库push显示

背景&#xff1a; 在做测试时发现harbor仓库端口开放这&#xff0c;却一直登录不上去&#xff0c;重启harbor资源包docker-compose还是不行&#xff0c;修改了docker.service文件不行&#xff0c;json文件也不行&#xff0c;以下是涉及到的命令和报错&#xff08;好像是这个&a…

C语言指针详解-上

C语言指针详解-上 前言1.指针的基本概念1.1指针是什么1.2指针的声明与初始化1.3取地址符&和解引用符*& 运算符用于**获取变量的地址*** 运算符用于访问指针指向的值 2.指针的类型常见数据类型的指针指针与数组、字符串数组指针结构体指针函数指针二级指针void指针 3.指…

对零基础想转行网络安全同学的一点建议

最近有同学在后台留言&#xff0c;0基础怎么学网络安全&#xff1f;0基础可以转行做网络安全吗&#xff1f;以前也碰到过类似的问题&#xff0c;想了想&#xff0c;今天简单写一下。 我的回答是先了解&#xff0c;再入行。 具体怎么做呢&#xff1f; 首先&#xff0c;你要确…

进程地址空间(二)

目录 前言1. 进程地址空间究竟是什么2. 为什么要有进程地址空间2.1 让进程以统一的视角看待内存结构2. 2 保护物理内存2.3 进程管理 与 内存管理模块 的解耦合2.3.1 页表地址2.3.2 页表的权限管理2.3.3 关于进程挂起 && 惰性加载 4. 进程独立性的体现 前言 接着上篇文…

滑动变阻器的未来发展趋势和前景如何?是否有替代品出现?

滑动变阻器是常见的电子元件&#xff0c;主要用于调节电路中的电阻值。随着科技的不断发展&#xff0c;滑动变阻器的未来发展趋势和前景也引起了广泛关注。 滑动变阻器的未来发展将更加注重智能化&#xff0c;随着物联网、人工智能等技术的快速发展&#xff0c;滑动变阻器也将与…

git stash详细教程

git stash详细教程 基本命令: git stash: 保存当前未提交的更改&#xff0c;并恢复到干净的工作目录。git stash list: 列出所有的 stash。git stash show: 显示最新 stash 的简要内容。git stash show -p: 显示最新 stash 的详细内容。 应用和删除: git stash apply: 应用最新…