go 协程练习例题
go 协程练习例题
- 例1:统计 1-200000 的数字中,哪些是素数
- 例2:使用单通道、2个协程交替读取字符串
- 例3:使用1个管道,2个协程写数据、1个协程读
- 例4:完成一个并发任务调度器,按照指定顺序执行一系列任务
- 例5:并发计算数组的和
例1:统计 1-200000 的数字中,哪些是素数
使用并发/并行的方式,将统计素数的任务分配给多个(4 个)goroutine 去完成。
package mainimport ("fmt""time"
)// 统计 1-8000 的数字中,哪些是素数
func main() {// 用来放1000个数据var intChan = make(chan int, 1000)// 存放最终的素数结果var primeChan = make(chan int, 2000)// 用来判断程序什么时候退出var exitChan = make(chan bool, 4)go PutNum(intChan)// 开4条来判断是否是素数的协程for i := 0; i < 4; i++ {go PrimeNum(intChan, primeChan, exitChan)}// 当我们可以从exitChan 中取出4个数据的时候,才可以关闭primeChango func() {// 这里会发生阻塞,当boolChan 可以取出四个数据后,程序继续向下运行for i := 0; i < 4; i++ {<-exitChan}// 当我们从exitChan 取出4的数据的时候,说明四条判断是否为素数的协程都以及运行完了,这时候就可以放心的关闭primeChan了close(primeChan)}()// 不断的从primeChan 当中取出数据,直到 primeChan 为空,而且primeChan已经关闭for {v, ok := <-primeChanif !ok {break}fmt.Print(v, " ")}}// 不断的写入 1-8000 的数据
func PutNum(intChan chan int) {for i := 1; i <= 8000; i++ {intChan <- i}close(intChan)
}// 判断 intChan 中的数据 是否为素数,如果是素数,就加到primeChan 中
func PrimeNum(intChan chan int, primeChan chan int, exitChan chan bool) {for {time.Sleep(time.Millisecond * 10)num, ok := <-intChan// 如果intChan管道里面没有数据了,跳出循环if !ok {break}// 判断取出的数是否为素数var flag bool = truefor i := 2; i < num; i++ {if num%i == 0 {flag = falsebreak}}// 如果是素数,就添加到 primeChan 中if flag {primeChan <- num}}fmt.Println("有一个 primeNum 协程因为取不到数据,退出")// 给 exitChan 添加一个数据,表示这条协程运行结束了exitChan <- true
}
例2:使用单通道、2个协程交替读取字符串
思路:两个协程并发,一个协程读完然后往通道里写数据,另一个协程写完然后读数据,两个协程交替进行,交替阻塞。(利用无缓冲通道的特性)
package mainimport ("fmt""sync"
)var dataCh = make(chan byte)
var sw sync.WaitGroup
var index int64 = 0
var str = "hello wrold!!"func main() {sw.Add(2)go desk1()go desk2()sw.Wait()
}func desk1() {defer sw.Done()for {v, ok := <-dataChif !ok {return}fmt.Println("desk1 读取数据,内容为", string(v))if index < int64(len(str)) {dataCh <- str[index]index++// atomic.AddInt64(&index, 1) // 原子操作,其实也不用进行原子操作,因为两个协程每次只运行一个,不会出现并发冲突} else {close(dataCh) // 两个协程都有 close(dataCh) ,但是只会执行一次,因为另一个close不会到达return}}
}func desk2() {defer sw.Done()for {if index < int64(len(str)) {dataCh <- str[index]index++// atomic.AddInt64(&index, 1)} else {close(dataCh)return}v, ok := <-dataChif !ok {return}fmt.Println("desk2 读取数据,内容为", string(v))}
}
例3:使用1个管道,2个协程写数据、1个协程读
注意通道关闭时机。
package mainimport ("fmt""sync""sync/atomic"
)var ch = make(chan int, 5) // 存数据
var sw sync.WaitGroup
var num int64 // 用来记录通道关闭的时机func main() {// 设置GMP中的P:更改参数为1或者2,然后比较一下从管道中取出来的数据顺序// runtime.GOMAXPROCS(1)sw.Add(1)go readData()sw.Add(2)go writeData(1, 10)go writeData(11, 20)sw.Wait()
}func readData() {defer sw.Done()// for v := range ch {// fmt.Println(v)// }// fmt.Println("readData 退出了")// 或者:不仅要会用 for ... range,还要多会用 for 和 select 的组合for {select {case v, ok := <-ch:if !ok {return}fmt.Println(v)}}
}func writeData(start, end int) {defer sw.Done()for i := start; i <= end; i++ {ch <- i}// 原子操作atomic.AddInt64(&num, 1)// 在第二个写数据的管道执行完毕之后才可以关闭 chif num == 2 {fmt.Println(num, "关闭了")close(ch)}
}
例4:完成一个并发任务调度器,按照指定顺序执行一系列任务
1、函数 AddTask(func()):向任务调度器添加任务。
2、函数 Start():启动任务调度器并开始执行任务。
3、要保证任务按照添加的顺序依次执行,即每个任务在前一个任务完成后才能开始执行。
package mainimport ("fmt""sync""time"
)type fu func()// 存放任务
var ch chan fuvar (addWg sync.WaitGroup // 添加任务executeWg sync.WaitGroup // 执行任务
)func init() {ch = make(chan fu, 4)
}// AddTask 添加任务
func AddTask(f fu) {ch <- f
}// Start 开始执行任务
func Start() {executeWg.Add(1)go func() {defer executeWg.Done()for f := range ch {f()}}()addWg.Wait() // 等待所有任务添加完毕executeWg.Wait() // 等待所有任务执行完毕fmt.Println("所有任务添加并执行完毕")
}func main() {addWg.Add(1)go func() {// 添加任务结束后关闭管道defer close(ch)defer addWg.Done() // 确保任务添加完毕后通知主协程AddTask(fu(func() {fmt.Println("执行任务1")}))AddTask(fu(func() {fmt.Println("执行任务2")}))AddTask(fu(func() {fmt.Println("执行任务3")}))// 休眠2s,表示这两秒内没有任务time.Sleep(2 * time.Second)AddTask(fu(func() {fmt.Println("执行任务4")}))time.Sleep(1 * time.Second)AddTask(fu(func() {fmt.Println("执行任务5")}))AddTask(fu(func() {fmt.Println("执行任务6")}))AddTask(fu(func() {fmt.Println("执行任务7")}))}()Start()
}
例5:并发计算数组的和
创建一个程序,计算一个大数组的和,使用多个 goroutine 分担计算任务。将数组分成若干部分,每个部分由一个 goroutine 计算其部分的和,然后将部分和合并得到最终结果。
package mainimport ("fmt""sync""sync/atomic"
)var sw sync.WaitGroup
var sum int32func main() {var sli = []int{1, 3, 453, 2, 5, 7, 3, 2, 6, 3, 6, 3, 6, 299, 2352, 2229, 23, 8}for i := 0; i < len(sli); i += 5 {sw.Add(1)if i+5 > len(sli) {go sumFu(sli[i:])} else {go sumFu(sli[i : i+5])}}sw.Wait()fmt.Println(sum) // 5411demo := 0for i := 0; i < len(sli); i++ {demo += sli[i]}fmt.Println(demo) // 5411
}func sumFu(sli []int) {defer sw.Done()var demo intfor _, v := range sli {demo += v}atomic.AddInt32(&sum, int32(demo))
}
相关文章:
go 协程练习例题
go 协程练习例题 例1:统计 1-200000 的数字中,哪些是素数例2:使用单通道、2个协程交替读取字符串例3:使用1个管道,2个协程写数据、1个协程读例4:完成一个并发任务调度器,按照指定顺序执行一系列…...
JAVA:访问者模式(Visitor Pattern)的技术指南
1、简述 访问者模式(Visitor Pattern)是一种行为型设计模式,允许你将操作分离到不同的对象中,而无需修改对象本身的结构。这种模式特别适合复杂对象结构中对其元素进行操作的场景。 本文将介绍访问者模式的核心概念、优缺点,并通过详细代码示例展示如何在实际应用中实现…...
如何实现邮箱+验证码登录功能(express+vue+MySQL版)
目录 1. 初始化项目2. 配置环境变量3. 更新数据库4. 编写路由函数5. 前端调用接口 1. 初始化项目 前端根目录:/web 后端根目录:/api_server 安装依赖: npm install express mysql nodemailer randomstring dotenv其中,nodemaile…...
Pycharm访问MySQL数据库·上
1.MySQL驱动模块Connector #导入数据库的驱动工具 import mysql.connector #连接数据库必备的条件 config {"host": "localhost","port": 3306,"user": "root","password": "888888","database&…...
vscode+msys2+clang+xmake c++开发环境搭建
转载请标明出处:小帆的帆的专栏 安装msys2 下载msys2安装包:清华源下载地址安装msys2:安装目录,C:\Softwares\msys64 安装cling工具链,xmake !!!在开始菜单中启动MSYS2 CLANG64,…...
Python面试常见问题及答案5
一、基础语法相关 问题1: Python的可变数据类型和不可变数据类型有哪些? 答案: 在Python中,可变数据类型有列表(list)、字典(dict)、集合(set)。这些数据类型…...
威联通docker无法拉取镜像
链接:威联通TS-464C 折腾--Container Station国内无法拉取镜像_docker_wangguanghe-开放原子开发者工作坊我这里用的是IPV6 ,没有公网资源啊。 wangguanghe...
3D 生成重建034-NerfDiff借助扩散模型直接生成nerf
3D 生成重建034-NerfDiff借助扩散模型直接生成nerf 文章目录 0 论文工作1 论文方法2 实验结果 0 论文工作 感觉这个论文可能能shapE差不多同时期工作,但是shapE是生成任意种类。 本文提出了一种新颖的单图像视图合成方法NerfDiff,该方法利用神经辐射场 …...
ASP.net Core EntityFramework Code EF code 汇总
Entity FrameWork EF 总结 EF Core EF Core 如果实体模型很多,全部放在 上下文中的 OnModelCreating(ModelBuilder modelBuilder) 不太好维护 可以把实体模型 分离出去,每个类创建一个实体模型 public class BookConfiguration :IEntityT…...
AtCoder Beginner Contest 384 Solution
文章目录 ABCDEFG A void solve() {string s; char x, y;qr(n, x, y, s);for(auto i: s) {if(i ! x) i y;cout << i;} }B void solve() {qr(n, m);for (int i 1; i < n; i) {int x, y;qr(x, y);x--;if(1600 - x * 400 < m && m < 2799 - x * 400) m…...
c# TaskScheduler
这里记录下 TaskScheduler 的简单用法。 使用场景: 使用 Task 的时候,大家知道用 TaskFactory.StartNew 可以用来创建一个 Task 。这里如果创建了 3 个,那么这3个 Task 就各自放飞直接运行了。 class Program {private static TaskFactory…...
FFMPEG视频转图片
用FFMPEG视频转图片,并且for循环 import os import subprocess# 输入文件夹和输出文件夹路径 input_folder r"I:\xxx" output_base_folder r"D:\xxx\YOLO\data\video" output_subfolder_name "20240609"# 创建输出子文件夹 output…...
激活函数-swiGLU
swiGLU(Switch Gated Linear Unit)简介 swiGLU 是一种改进的激活函数模块,主要用于深度学习中的 Transformer 模型和其他神经网络架构。它在 GLU(Gated Linear Unit) 的基础上进行了修改,以提升模型的表现…...
PCIe学习笔记
PCIE高速串行数据总线 当拿到一块板子 比如你要用到PCIE 首先要看这块板子的原理图 一般原理图写的是 PCI express 表示PCIE 以下是Netfpga为例下的PCIE插口元件原理图 ——PMT简介
一、引言 PMT(Program Map Table)与PAT表成对出现,其PID由PAT表给出。通过PMT表可以得到该节目包含的视频和音频信息,从而找到音视频流: 二、PMT表中的属性 根据《T-REC-H.222.0-202106-S!!PDF-E.pdf》第79页&#x…...
2024小迪安全信息收集第三课
目录 一、Web应用-架构分析-WAF&蜜罐识别 二、Web应用-架构分析-框架组件指纹识别 #Web架构 开源CMS 前端技术 开发语言 框架组件 Web服务器 应用服务器 数据库类型 操作系统信息 应用服务信息 CDN信息 WAF信息 蜜罐信息 其他组件信息 #指纹识别 #WAF识别…...
ESP32-C3 入门笔记07: ESP-NOW动态绑定MAC地址. (ESP-IDF + VSCode)
ESP-NOW 简介 ESP-NOW [gitbuh] ESP-NOW 是一种由乐鑫公司定义的无连接 Wi-Fi 通信协议。在 ESP-NOW 中,应用程序数据被封装在各个供应商的动作帧中,然后在无连接的情况下,从一个 Wi-Fi 设备传输到另一个 Wi-Fi 设备。 CTR 与 CBC-MAC 协…...
Windows如何安装go环境,离线安装beego
一、安装go 1、下载go All releases - The Go Programming Language 通过网盘分享的文件:分享的文件 链接: https://pan.baidu.com/s/1MCbo3k3otSoVdmIR4mpPiQ 提取码: hxgf 下载amd64.zip文件,然后解压到指定的路径 2、配置环境变量 需要新建两个环境…...
【Unity技巧】如何设置屏幕最小宽度
在 Unity 中,设置屏幕最小宽度可以通过调整 Canvas 的 CanvasScaler 组件来控制 UI 元素的缩放,并确保 UI 在不同屏幕宽度下始终能保持适当的布局。 不过,如果你想要限制游戏的实际窗口宽度,通常是通过代码来实现的。例如&#x…...
【新版】阿里云ACP云计算题库及答案解析
阿里云ACO云计算考试提醒都是选择题,70道单选题30道单选题,聪明的小伙伴都知道刷题备考加深记忆,给大家分享一波阿里云ACP云计算题库及答案,希望对大家顺利拿到阿里云ACP云计算高级工程师证书有所帮助! 1、设计云上架…...
【蓝桥杯每日一题】推导部分和——带权并查集
推导部分和 2024-12-11 蓝桥杯每日一题 推导部分和 带权并查集 题目大意 对于一个长度为 ( N ) 的整数数列 A 1 , A 2 , ⋯ , A N A_1, A_2, \cdots, A_N A1,A2,⋯,AN ,小蓝想知道下标 ( l ) 到 ( r ) 的部分和 ∑ i l r A i A l A l 1 ⋯ A r \sum_{…...
【Linux服务器nginx前端部署详解】ubantu22.04,前端Vue项目dist打包
本文主要讲一下在Linux系统环境下(以ubantu22.04为例),如何用nginx部署前端Vue项目打包的dist静态资源。有些具体的命令就不展开讲了,可以自行查看其他博主的文章,我主要讲整体的步骤和思路。 一、ubantu系统安装ngin…...
Groovy 语法快速入门
文章目录 1. Groovy 的特点2. 基本语法2.1. 变量2.2. 字符串2.3. 条件语句 3. 集合操作3.1. 列表(List)3.2. 映射(Map) 4. 循环语句4.1. 普通循环4.2. 闭包遍历 5. 方法定义6. 闭包(Closure)6.1. 定义与调用…...
vue3 Textarea在光标定位处,增加一定的关键词。
1、经常碰到这种情况,有一些是系统预留的关键词可以选择,当用户把光标定位到什么地方,我们就要在这个位置插入指定的关键词。 2、光标定位在今天的前面,那么我们点击【逗号】按钮,在这个位置增加一个逗号。 3、代码&…...
硬件设计-电源轨噪声对时钟抖动的影响
目录 定义 实际案例 总结 定义 首先了解抖动的定义,在ITU-T G.701中有关抖动的定义如下: 数字信号重要瞬间相对于其理想时间位置的短期非累积变化。 抖动是时钟或数据信号时序的短期时域变化。抖动包括信号周期、频率、相位、占空比或其他一些定时特…...
Graspness 端到端抓取点估计 | 环境搭建 | 模型推理测试
在复杂场景中实现抓取检测,Graspness是一种端到端的方法; 输入点云数据,输出抓取角度、抓取深度、夹具宽度等信息。 开源地址:https://github.com/rhett-chen/graspness_implementation?tabreadme-ov-file 论文地址࿱…...
大模型呼入机器人的缺点是什么?(转)
大模型呼入机器人的缺点是什么?(转) 原作者:开源呼叫中心FreeIPCC,其Github:https://github.com/FreeIPCC/FreeIPCC 大模型呼入机器人在提供高效、自动化服务的同时,也存在一些缺点。以下是对其缺点的详细归纳&#…...
ASP.NET |日常开发中连接Oracle数据库详解
ASP.NET |日常开发中连接Oracle数据库详解 前言一、安装和配置 Oracle 数据访问组件1.1 安装ODP.NET(Oracle Data Provider for.NET):1.2 引用相关程序集: 二、配置连接字符串2.1 连接字符串的基本组成部分:…...
Kaggler日志-Day4
进度24/12/14 昨日复盘: Pandas课程完成 Intermediate Mechine Learning2/7 今日记录: Intermediate Mechine Learning之类型变量 读两篇讲解如何提问的文章,在提问区里发起一次提问 实战:自己从头到尾首先Housing Prices Compe…...
onnx算子的注册详解及案例 (完整版)
文章目录 1. 介绍1.1 导出onnx不成功1.2 分析和解决方案2. 案例2.1 Asinh算子注册2.1.1 导出onnx2.1.2 算子注册2.2 自定义算子的注册2.1 直接导出自定义算子2.2 自定义算子的注册并导出2.3 导出带deformable conv 的onnx2.3.1 直接导出deformable conv2.3.2 注册并导出deforma…...
2024生命科学前沿技术
前沿技术是指高技术领域中具有前瞻性、先导性和探索性的重大技术,是未来高技术更新换代和新兴产业发展的重要基础,是国家高技术创新能力的综合体现。选择前沿技术的主要原则一是代表世界高技术前沿的发展方向。二是对国家未来新兴产业的形成和发展具有引…...
游戏引擎学习第47天
仓库: https://gitee.com/mrxiao_com/2d_game 昨天我们花了一点时间来修复一个问题,但基本上是在修复这个问题的过程中,我们决定添加一个功能,那就是在屏幕上控制多个实体。所以如果我有一个手柄,我可以添加另一个角色࿰…...
1.编写 Prompt 的原则
一、环境配置 使用 OpenAI 的 ChatGPT API,需要有 API_KEY,并安装 OpenAI 库。安装命令:pip install openai 和 pip install zhipuai。配置方法:直接设置 openai.api_key 或通过环境变量设置。 二、两个基本原则 2.1 原则一&am…...
【JavaEE】网络(2)
一、网络编程套接字 1.1 基础概念 【网络编程】指网络上的主机,通过不同的进程,以编程的方式实现网络通信;当然,我们只要满足进程不同就行,所以即便是同一个主机,只要是不同进程,基于网络来传…...
SAS - Subtractive Port
在SAS(串行连接SCSI,Serial Attached SCSI)协议中,subtractive port 是一种特殊类型的端口,主要用于设备间的路由功能。它的作用是在路径选择过程中充当默认路径,以处理未明确指定路径的请求。以下是它的定…...
Unity3D项目为什么要使用FairyGUI
前言 Unity3D项目选择使用FairyGUI的原因是多方面的,主要涵盖性能优化、设计模式、编辑器支持、跨平台兼容性以及丰富的功能特性。以下是对这些方面的详细解析以及相关的代码实现。 对惹,这里有一个游戏开发交流小组,希望大家可以点击进来一…...
Pytest接口自动化测试框架Python自动化测试开发
一、引言 在软件开发过程中,接口测试是确保软件各个组件之间数据传输和功能交互正常工作的重要环节。通过接口测试,可以提高软件的整体质量和稳定性。Pytest是一个流行的Python自动化测试框架,提供了丰富的断言方法和灵活的测试组织结构&…...
MySQL追梦旅途之性能优化
1、索引优化 索引可以显著加速查询操作,但过多或不适当的索引也会带来负面影响(如增加写入开销)。因此,选择合适的索引至关重要。 创建索引: 为经常用于WHERE子句、JOIN条件和ORDER BY排序的列创建索引。 CREATE I…...
数字校园:信息时代的教育新形态
现如今,我们生活在一个信息爆炸的时代,每一天都有海量的信息产生。而在教育领域,也正在经历一场数字化的变革,这就是所谓的“数字校园”。数字校园可不是简单的把课本搬到电脑上那么简单,它其实是一个综合性的平台&…...
数字产业化和产业数字化到底是什么?
“数字产业化”和“产业数字化”在很多官方文件和领导人讲话中都是成对出现的,这两个术语看起来非常相似,但它们作为数字经济的两个重要组成部分,既有联系又有区别。 在谈数字产业化和产业数字化之前,我这里需要先给大家介绍一个概…...
每日十题八股-2024年12月14日
1.类加载器有哪些? 2.双亲委派模型的作用 3.讲一下类加载过程? 4.讲一下类的加载和双亲委派原则 5.什么是Java里的垃圾回收?如何触发垃圾回收? 6.判断垃圾的方法有哪些? 7.垃圾回收算法是什么,是为了解决了…...
大模型呼入机器人有哪些功能特点?(转)
大模型呼入机器人有哪些功能特点?(转) 原作者:开源呼叫中心FreeIPCC,其Github:https://github.com/lihaiya/freeipcc 大模型呼入机器人,作为现代通信技术与人工智能深度融合的产物,正逐渐成为企业提升服务…...
EasyExcel设置表头上面的那种大标题(前端传递来的大标题)
1、首先得先引用easyExcel的版本依赖,我那 <dependency><groupId>com.alibaba</groupId><artifactId>easyexcel</artifactId><version>2.2.6</version> </dependency> 2、然后得弄直接的实体类,&…...
[笔记] 编译LetMeowIn(C++汇编联编程序)过程
文章目录 前言过程下载源码vs2017 创建空项目 引入编译文件改项目依赖属性改汇编编译属性该项目还需注意编译运行 总结 前言 编译LetMeowin 项目发现是个混编项目,c调用汇编的程序,需要配置一下,特此记录一下 过程 下载源码 首先下载源码…...
(三)机器学习 - 标准差/方差
标准差 标准差是统计学中一个非常重要的概念,它用来衡量一组数据的离散程度,即数据点与平均值之间的偏离程度。标准差越大,表示数据点越分散;标准差越小,表示数据点越集中。 标准差的计算步骤如下: 计算数…...
笔记:在WPF中InvalidateMeasure,InvalidateArrange,InvalidateVisual,UpdateLayout主要功能
一、目的:简要介绍在WPF中InvalidateMeasure,InvalidateArrange,InvalidateVisual,UpdateLayout主要功能 在 WPF 中,InvalidateMeasure、InvalidateArrange、InvalidateVisual 和 UpdateLayout 是用于控制布局系统的四…...
[笔记]Qt下使用SendMessage、PostMessage和接收window消息
1.头文件和库引用 首先必须要包含windows.h这个头文件,如果使用一些扩展函数,还需要包含windowsx.h。网上说使用FindWindow要添加头文件winuser.h,不过应该windows.h是自动包含这个依赖的(我没有添加) #include <…...
使用echarts实现3d柱状图+折线图
以下代码有问题请直接问国内直连GPT/Claude HTML 需要注意threeDchart一定要设置宽度高度,不然图不显示,然后echarts版本不要太低,不然也不显示 <div id"threeDchart" class"threeDchart"></div>js set3DBarChart2(dat…...