Golang —协程池(panjf2000/ants/v2)

news/2025/2/6 0:31:13/

Golang —协程池(panjf2000/ants/v2)

  • 1 ants
    • 1.1 基本信息
    • 1.2 ants 是如何运行的(流程图)

1 ants

1.1 基本信息

代码地址:github.com/panjf2000/ants/v2
介绍:ants是一个高性能的 goroutine 池,实现了对大规模 goroutine 的调度管理、goroutine 复用,允许使用者在开发并发程序的时候限制 goroutine 数量,复用资源,达到更高效执行任务的效果。

功能

  • 自动调度海量的 goroutines,复用 goroutines。
  • 定期清理过期的 goroutines,进一步节省资源。
  • 提供了大量有用的接口:任务提交、获取运行中的 goroutine 数量、动态调整 Pool 大小、释放 Pool、重启 Pool。
  • 优雅处理 panic,防止程序崩溃。
  • 资源复用,极大节省内存使用量;在大规模批量并发任务场景下比原生 goroutine 并发具有更高的性能。
  • 非阻塞机制。

1.2 ants 是如何运行的(流程图)

在这里插入图片描述

  1. 这里每一个worker其实就是一个单独的协程。Submit()就是将一个任务交给worker(协程)来异步处理,等任务执行完后,worker会将自己交还给协程池。
  2. 倘若回归协程池失败,或者用户提交了一个空的任务包,则该 goWorker 会被销毁,销毁方式是将自身放回协程池的对象池 workerCache. 并且会调用协调器 cond 唤醒一个阻塞等待的协程。
  3. 通过使用 ants,可以实例化一个 goroutine 池,复用 goroutine ,节省资源,提升性能,它会自动管理worker(协程)的创建、回收、释放等工作。

http://www.ppmy.cn/news/1569652.html

相关文章

Linux 系统上安装 Docker 并进行配置

Docker 是一种开源的应用容器引擎,它允许开发者打包他们的应用以及应用的依赖包到一个可移植的容器中,然后发布到任何流行的 Linux 机器上,也可以实现虚拟化。容器是完全使用沙箱机制,相互之间不会有任何接口(类似 iPh…

C++输入输出(上)

cin和cout cin是C中提供的标准输入流对象,一般针对的是键盘,也就是从键盘上输入的字符流,使用 cin来进行数据的提取,cin一般是和 >> (流提取运算符) 配合使用的。 cin的功能和scanf是类似的 cout是C中提供的标准输出流对象,一般针对的是控制台的窗口,也就是将数据以字符…

面向npm的实时仪表板Dashly

之前介绍过读取 npm 日志的 GoAccess,这次介绍的是能动态跟踪和显示您 npm 中所有服务的轻量级实时仪表板 – Dashly 简介 什么是 Dashly ? Dashly 是一个为 Nginx Proxy Manager 用户定制的实时仪表板。它通过自动与 NPM 数据库同步来简化您监控和组织…

mysql中in和exists的区别?

大家好,我是锋哥。今天分享关于【mysql中in和exists的区别?】面试题。希望对大家有帮助; mysql中in和exists的区别? 在 MySQL 中,IN 和 EXISTS 都是用于子查询的操作符,但它们在执行原理和适用场景上有所不…

使用numpy自定义数据集 使用tensorflow框架实现逻辑回归并保存模型,然后保存模型后再加载模型进行预

1. 引言 逻辑回归(Logistic Regression)是一种常见的分类算法,广泛应用于二分类问题。在本篇博客中,我们将使用numpy生成一个简单的自定义数据集,并使用TensorFlow框架构建和训练逻辑回归模型。训练完成后&#xff0c…

Elasticsearch Queries

Elasticsearch Compound Queries Elasticsearch 的 Compound Queries 是一种强大的工具,用于组合多个查询子句,以实现更复杂的搜索逻辑。这些查询子句可以是叶查询(Leaf Queries)或复合查询(Compound Queries&#xf…

P3199 【[HNOI2009]最小圈】

疑似三倍经验 因为和机房一些大佬一起做的这道题,所以emmm他们貌似也写了题解,在做这道题的时候也参照了其他大佬写的一些题解,所以如果程序有雷同请见谅(手动鞠躬) 题目也是莫名其妙地给了一大串数学式,简…

记录一次-Rancher通过UI-Create Custom- RKE2的BUG

一、下游集群 当你的下游集群使用Mysql外部数据库时,会报错: **他会检查ETCD。 但因为用的是Mysql外部数据库,这个就太奇怪了,而且这个检测不过,集群是咩办法被管理的。 二、如果不选择etcd,就选择控制面。 在rke2-…