协程是否越多越好

2024-05-16 11:52
文章标签 是否 越多越好 协程

本文主要是介绍协程是否越多越好,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

写在文章开头

我们都说协程是活跃于应用层的轻量级线程,进行调度切换时的开销远远小于线程,那么问题来了,对于高并发的场景,协程是否是越多越好呢?对此本文就会基于几个案例和go语言设计层面的角度来剖析这个问题。

在这里插入图片描述

Hi,我是 sharkChili ,是个不断在硬核技术上作死的 java coder ,是 CSDN的博客专家 ,也是开源项目 Java Guide 的维护者之一,熟悉 Java 也会一点 Go ,偶尔也会在 C源码 边缘徘徊。写过很多有意思的技术博客,也还在研究并输出技术的路上,希望我的文章对你有帮助,非常欢迎你关注我的公众号: 写代码的SharkChili

因为近期收到很多读者的私信,所以也专门创建了一个交流群,感兴趣的读者可以通过上方的公众号获取笔者的联系方式完成好友添加,点击备注 “加群” 即可和笔者和笔者的朋友们进行深入交流。

在这里插入图片描述

多协程代码示例

我们给出一段代码示例,这段代码会进行一个大循环创建多个协程调用foo方法:

func foo() {//休眠1s后输出time.Sleep(time.Second)
}func main() {//大循环启动大量协程for i := 0; i < math.MaxInt64; i++ {go func() {foo()}()}//休眠 让上述协程执行time.Sleep(time.Hour)
}

程序执行完一段时间后报错,提示操作了大量的文件或者socket,很明显go在使用协程提升并发性能的同时也对服务器资源的使用做了限制。
所以,对于协程的使用,我们应做到如何使用尽可能少的协程做尽快尽多的任务:

panic: too many concurrent operations on a single file or socket (max 1048575)goroutine 1162454 [running]:

协程并发最佳实践

逻辑优化

协程设计的初衷就是线程用后即焚,所以从业角度考虑,假设我们开大量协程执行耗时任务,这就会导致单位时间内有大量的协程都活跃与内存中,无法做到即用即毁,随着时间的推移就看你会把内存资源耗尽。所有我们建议在使用协程进行业务开发时,尽可能的优化任务的执行速度。
以我们上文为例,造成too many concurrent operations on a single file or socket的本质原因就是内存中存在大量的协撑爆了服务器的内存资源,所以如果我们能够提升每一个协程的执行速度,保证单位时间内尽可能处理多的协程,保证大量协程能够及时GC以保证时刻保持足量的内存空间,就能够避免上述问题:

在这里插入图片描述

对应我们将foo休眠的逻辑去掉,以模拟协程毫秒级处理,最终代码正确执行完成了:

func foo() {//模拟协程毫秒级的处理
}func main() {i := 0//大循环启动大量协程for ; i < math.MaxInt64; i++ {go func() {foo()}()}//等待上述协程执行完成var wg sync.WaitGroupwg.Add(1)go func() {for true {//当所有协程执行完成之后,该协程退出循环if i == math.MaxInt64 {wg.Done()break}time.Sleep(1 * time.Minute)}}()//所有协程执行完成后输出finishwg.Wait()fmt.Println("finish")}

利用channel实现协程有界化

产生上述的原因就是单位时间内创建了太多了协程,所以我们可以通过有缓冲区的channel作为信号量,只有信号可以投递到缓冲区中才能创建协程,由此实现单位时间内仅能创建有限量的协程,从而避免内存溢出:
在这里插入图片描述

对应的我们给出这段思路的代码:

func foo(ch chan struct{}) {fmt.Println("hello")time.Sleep(time.Second)//完成执行后,将信号从channel中抛出<-ch
}func main() {//创建channel允许容纳5000个元素ch := make(chan struct{}, 5000)//创建大量协程for i := 0; i < math.MaxInt64; i++ {//投递信号到协程中,只有投递成功才能执行后续逻辑ch <- struct{}{}//创建协程并运行go func() {foo(ch)}()}}

协程池化

从一个Java程序员的角度出发,大部分都认为协程应该可以向线程一样通过池化进行复用,但是我们不推荐这种做法,因为go语言本身就内置对协程池化的管理机制,并且协程的使用初衷就是即用即毁,避免池化,所以这个方案我们不推荐。

终极大招

提升服务器硬件配置,俗称:换个高配CPU、加内存。

在这里插入图片描述

小结

以上便是笔者对于协程创建的量的问题的思考和总结,希望对你有帮助。

我是 sharkchiliCSDN Java 领域博客专家开源项目—JavaGuide contributor,我想写一些有意思的东西,希望对你有帮助,如果你想实时收到我写的硬核的文章也欢迎你关注我的公众号: 写代码的SharkChili
因为近期收到很多读者的私信,所以也专门创建了一个交流群,感兴趣的读者可以通过上方的公众号获取笔者的联系方式完成好友添加,点击备注 “加群” 即可和笔者和笔者的朋友们进行深入交流。

在这里插入图片描述

这篇关于协程是否越多越好的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/994833

相关文章

Android Kotlin 高阶函数详解及其在协程中的应用小结

《AndroidKotlin高阶函数详解及其在协程中的应用小结》高阶函数是Kotlin中的一个重要特性,它能够将函数作为一等公民(First-ClassCitizen),使得代码更加简洁、灵活和可... 目录1. 引言2. 什么是高阶函数?3. 高阶函数的基础用法3.1 传递函数作为参数3.2 Lambda

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D

C#比较两个List集合内容是否相同的几种方法

《C#比较两个List集合内容是否相同的几种方法》本文详细介绍了在C#中比较两个List集合内容是否相同的方法,包括非自定义类和自定义类的元素比较,对于非自定义类,可以使用SequenceEqual、... 目录 一、非自定义类的元素比较1. 使用 SequenceEqual 方法(顺序和内容都相等)2.

查询Oracle数据库表是否被锁的实现方式

《查询Oracle数据库表是否被锁的实现方式》本文介绍了查询Oracle数据库表是否被锁的方法,包括查询锁表的会话、人员信息,根据object_id查询表名,以及根据会话ID查询和停止本地进程,同时,... 目录查询oracle数据库表是否被锁1、查询锁表的会话、人员等信息2、根据 object_id查询被

shell脚本快速检查192.168.1网段ip是否在用的方法

《shell脚本快速检查192.168.1网段ip是否在用的方法》该Shell脚本通过并发ping命令检查192.168.1网段中哪些IP地址正在使用,脚本定义了网络段、超时时间和并行扫描数量,并使用... 目录脚本:检查 192.168.1 网段 IP 是否在用脚本说明使用方法示例输出优化建议总结检查 1

如何测试计算机的内存是否存在问题? 判断电脑内存故障的多种方法

《如何测试计算机的内存是否存在问题?判断电脑内存故障的多种方法》内存是电脑中非常重要的组件之一,如果内存出现故障,可能会导致电脑出现各种问题,如蓝屏、死机、程序崩溃等,如何判断内存是否出现故障呢?下... 如果你的电脑是崩溃、冻结还是不稳定,那么它的内存可能有问题。要进行检查,你可以使用Windows 11

Codeforces Round #113 (Div. 2) B 判断多边形是否在凸包内

题目点击打开链接 凸多边形A, 多边形B, 判断B是否严格在A内。  注意AB有重点 。  将A,B上的点合在一起求凸包,如果凸包上的点是B的某个点,则B肯定不在A内。 或者说B上的某点在凸包的边上则也说明B不严格在A里面。 这个处理有个巧妙的方法,只需在求凸包的时候, <=  改成< 也就是说凸包一条边上的所有点都重复点都记录在凸包里面了。 另外不能去重点。 int

easyui同时验证账户格式和ajax是否存在

accountName: {validator: function (value, param) {if (!/^[a-zA-Z][a-zA-Z0-9_]{3,15}$/i.test(value)) {$.fn.validatebox.defaults.rules.accountName.message = '账户名称不合法(字母开头,允许4-16字节,允许字母数字下划线)';return fal

【408DS算法题】039进阶-判断图中路径是否存在

Index 题目分析实现总结 题目 对于给定的图G,设计函数实现判断G中是否含有从start结点到stop结点的路径。 分析实现 对于图的路径的存在性判断,有两种做法:(本文的实现均基于邻接矩阵存储方式的图) 1.图的BFS BFS的思路相对比较直观——从起始结点出发进行层次遍历,遍历过程中遇到结点i就表示存在路径start->i,故只需判断每个结点i是否就是stop