协程是否越多越好

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

相关文章

Python如何判断字符串中是否包含特殊字符并替换

《Python如何判断字符串中是否包含特殊字符并替换》这篇文章主要为大家详细介绍了如何使用Python实现判断字符串中是否包含特殊字符并使用空字符串替换掉,文中的示例代码讲解详细,感兴趣的小伙伴可以了... 目录python判断字符串中是否包含特殊字符方法一:使用正则表达式方法二:手动检查特定字符Pytho

Python多进程、多线程、协程典型示例解析(最新推荐)

《Python多进程、多线程、协程典型示例解析(最新推荐)》:本文主要介绍Python多进程、多线程、协程典型示例解析(最新推荐),本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定... 目录一、multiprocessing(多进程)1. 模块简介2. 案例详解:并行计算平方和3. 实现逻

Python如何精准判断某个进程是否在运行

《Python如何精准判断某个进程是否在运行》这篇文章主要为大家详细介绍了Python如何精准判断某个进程是否在运行,本文为大家整理了3种方法并进行了对比,有需要的小伙伴可以跟随小编一起学习一下... 目录一、为什么需要判断进程是否存在二、方法1:用psutil库(推荐)三、方法2:用os.system调用

Python中判断对象是否为空的方法

《Python中判断对象是否为空的方法》在Python开发中,判断对象是否为“空”是高频操作,但看似简单的需求却暗藏玄机,从None到空容器,从零值到自定义对象的“假值”状态,不同场景下的“空”需要精... 目录一、python中的“空”值体系二、精准判定方法对比三、常见误区解析四、进阶处理技巧五、性能优化

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