(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211164830.9 (22)申请日 2022.09.23 (71)申请人 山东倍科信息技 术有限公司 地址 250000 山东省济南市高新区齐盛广 场6号楼1 118室 申请人 山东旗帜信息有限公司 (72)发明人 李晓峰　邱瀚　 (74)专利代理 机构 济南皞通专利代理事务所 (普通合伙) 37369 专利代理师 周建峰 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 基于协程通信的高并发大数据处理方法、 系 统及电子设备 (57)摘要 本发明公开了一种基于协程通信的高并发 大数据处理方法、 系统及电子设备。 基于协程通 信的高并发大数据处理方法包括以下步骤： 接收 客户端发送的多个访问请求； 筛选访问请求， 根 据筛选后的所述访问请求启 用相应的协程， 供客 户端在所述相应的协程中执行所需的任务； 根据 现有的所述协程和/或筛选后的所述访问请求， 预测固定时间内所需的线程数量， 动态预留所需 数量的线程； 调用所述线程连接于所述协程， 为 所述协程的运行提供系统资源； 检测各个所述协 程的状态， 根据所述协程的状态， 断开或连接所 述线程与所述协程。 该发明可根据协程和/或访 问请求， 预测固定时间内所需的线程数量， 动态 预留所需数量的线程， 从而减少高并发大数据处 理时的卡顿。 权利要求书2页 说明书10页 附图6页 CN 115509746 A 2022.12.23 CN 115509746 A 1.基于协程 通信的高并发大 数据处理方法， 其特 征在于， 包括以下步骤： 接收客户端发送的多个访问请求； 筛选所述访 问请求， 根据所述筛选后的所述访 问请求启用相应的协程， 供所述客户端 在所述相应的协程中执 行所需的任务； 根据现有的所述协程和/或筛选后的所述访问请求， 预测固定时间内所需的线程数量， 动态预留所需数量的线程； 调用所述线程连接 于所述协程， 为所述协程的运行提供系统资源； 检测各个所述协程的状态， 根据所述协程的状态， 断开或连接所述线程与所述协程。 2.根据权利要求1所述的基于协程通信的高并发大数据处理方法， 其特征在于， 所述筛 选所述访问请求的方法包括： 对多个访问请求 查重， 找出同一 客户端发送的多个相同的访问请求； 删除同一客户端发送的部分相同的访问请求， 保留所述同一客户端发送的多个相同的 访问请求的其中一个。 3.根据权利要求2所述的基于协程通信的高并发大数据处理方法， 其特征在于， 根据 所 述筛选后的所述访问请求启用相应的协程的方法包括： 对所述访问请求分类； 对访问请求设置优先级， 其中， 同一类的所述访问请求设置为同一优先级； 根据所述访问请求的优先级， 按顺序为所述访问请求启用相应的协程。 4.根据权利要求3所述的基于协程通信的高并发大数据处理方法， 其特征在于， 对访问 请求设置优先级的方法包括： 将所述访问请求按照类别分配到所属的优先级； 将各个优先级的访问请求按照时间顺序依次排列； 对各个优先级的访问请求设置处 理比例。 5.根据权利要求2或3所述的基于协程通信的高并发大数据处理方法， 其特征在于， 根 据现有的所述协 程和/或筛选后的所述访问请求， 预测固定时间内所需的线程数量， 动态预 留所需数量的线程的方法包括： 根据同一种所述访 问请求平均消耗的系统资源， 预测固定时间内所需的线程数量， 动 态预留所需数量的线程； 和/或 根据现有的所述协程占用的线程的增长速度， 预测固定时间内所需的线程数量， 动态 预留所需数量的线程； 和/或 根据所述访问请求的类型以及和其他访问请求的相关程度， 预测固定时间内所需的线 程数量， 动态预留所需数量的线程。 6.根据权利要求5所述的基于协程通信的高并发大数据处理方法， 其特征在于， 根据同 一种所述访问请求平均消 耗的系统资源， 预测固定时间内所需的线程数量， 预测固定时间 内所需的线程数量的方法包括： 统计各种所述访问请求平均消耗的系统资源； 统计筛选后的所述访问请求的种类和数量； 根据未处理的所述访问情况的种类和数量以及各种所述访问请求平均消耗的系统资 源预测所需的系统资源；权　利　要　求　书 1/2 页 2 CN 115509746 A 2根据所述所需的系统资源预测所需的线程数量。 7.根据权利要求6所述的基于协程通信的高并发大数据处理方法， 其特征在于， 根据现 有的所述协程占用的线程的增长 速度， 预测固定时间内所需的线程数量的方法包括： 统计现有的所述协程占用的线程的增长 速度； 若所述增长速度持续第 二数量次超过预设的第 一正值， 且空闲线程的数量与总线程或 已使用线程的数量的比例低于第一预设值， 则申请创建新的线程， 直至空闲线程的数量与 总线程或已使用线程的数量的比例高于所述第一预设值 为止； 若所述增长速度持续第 三数量次低于预设的第 一负值， 且空闲的线程的数量与总 线程 或已使用线程的数量的比例高于第二预设值， 则销毁部分空闲的线程， 直至空闲线程的数 量与总线程或已使用线程的数量的比例低于所述第二预设值 为止。 8.根据权利要求7所述的基于协程通信的高并发大数据处理方法， 其特征在于， 动态预 留所需数量的线程的方法包括： 检测到所述线程小于所述预测固定时间内所需的线程数量 时， 向操作系统申请创建新 的线程； 检测到所述线程大于所述预测固定时间内所需的线程数量时， 销毁空 闲的线程。 9.基于协程 通信的高并发大 数据处理系统， 其特 征在于， 包括： 接收模块 （10） ， 用于 接收客户端发送的多个访问请求； 协程启用模块 （20） ， 用于筛选所述访问请求， 启用相应的协程， 供所述客户端在所述相 应的协程中执 行所需的任务； 线程预测模块 （30） ， 用于根据现有的所述协程和/或筛选后的所述访问请求， 预测固定 时间内所需的线程数量， 动态预留所需数量的线程； 线程连接模块 （40） ， 用于调用所述线程连接于所述协程， 为所述协程的运行提供系统 资源； 动态匹配模块 （50） ， 用于检测各个所述协程的状态， 根据所述协程的状态， 断开或连接 所述线程与所述协程。 10.一种电子设备， 其特征在于， 包括处理器和存储器， 所述存储器内存储有计算机程 序， 所述计算机程序被所述处理器执行时， 执行如权利要求1至8 中任一项所述的基于协程 通信的高并发大 数据处理方法。权　利　要　求　书 2/2 页 3 CN 115509746 A 3