0

0

如何在Golang中实现并发限流

P粉602998670

P粉602998670

发布时间:2025-10-14 17:12:02

|

591人浏览过

|

来源于php中文网

原创

使用带缓冲channel实现并发限流,通过固定容量channel作为许可证池控制最大并发数;2. 采用golang.org/x/sync/semaphore的WeightedSemaphore支持超时和上下文取消,适合复杂场景;3. 基于rate.Limiter控制请求速率,适用于API调用等需限频的场景;4. 根据需求选择合适方法:限并发用channel或信号量,限频率用rate.Limiter,可组合使用。

如何在golang中实现并发限流

在Golang中实现并发限流,核心目标是控制同时运行的协程数量,防止系统资源被耗尽。常用方法包括使用带缓冲的channel、semaphore(信号量)或第三方库如golang.org/x/sync/semaphore。下面介绍几种实用且清晰的实现方式。

使用Buffered Channel控制并发数

通过一个固定容量的channel来充当“许可证池”,每个goroutine执行前需先获取一个许可,执行完后归还。这种方式简单直观,适合大多数场景。

示例代码:

func main() {
    maxConcurrency := 3
    sem := make(chan struct{}, maxConcurrency)
for i := 0; i < 10; i++ {
    sem <- struct{}{} // 获取许可
    go func(id int) {
        defer func() { <-sem }() // 释放许可

        fmt.Printf("处理任务 %d\n", id)
        time.Sleep(2 * time.Second) // 模拟工作
        fmt.Printf("完成任务 %d\n", id)
    }(i)
}

// 等待所有任务完成(这里可用WaitGroup更精确)
time.Sleep(10 * time.Second)

}

dmSOBC SHOP网店系统
dmSOBC SHOP网店系统

dmSOBC SHOP网店系统由北京时代胜腾信息技术有限公司(http://www.webzhan.com)历时6个月开发完成,本着简单实用的理念,商城在功能上摒弃了外在装饰的一些辅助功能,尽可能的精简各项模块开发,做到有用的才开发,网店V1.0.0版本开发完成后得到了很多用户的使用并获得了好评,公司立即对网店进行升级,其中包括修正客户提出的一些意见和建议,现对广大用户提供免费试用版本,如您在使用

下载

立即学习go语言免费学习笔记(深入)”;

这种方式利用channel的阻塞特性自动实现限流,当channel满时,新的goroutine会等待,直到有空位。

使用golang.org/x/sync/semaphore

标准库没有原生信号量,但golang.org/x/sync包提供了WeightedSemaphore,支持异步获取,还能处理超时和上下文取消,更适合复杂控制。

安装:

go get golang.org/x/sync/semaphore

使用示例:

sem := semaphore.NewWeighted(3) // 最多3个并发

for i := 0; i < 10; i++ { if err := sem.Acquire(context.Background(), 1); err != nil { log.Printf("获取信号量失败: %v", err) continue }

go func(id int) {
    defer sem.Release(1)

    fmt.Printf("处理任务 %d\n", id)
    time.Sleep(2 * time.Second)
    fmt.Printf("完成任务 %d\n", id)
}(i)

}

立即学习go语言免费学习笔记(深入)”;

优势在于可结合context实现超时控制,例如:

ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)

基于Ticker的速率限流(RPS控制)

如果关注的是请求频率(如每秒最多10次),可以用time.Tickergolang.org/x/time/rate实现。

使用rate.Limiter示例:

import "golang.org/x/time/rate"

limiter := rate.NewLimiter(10, 1) // 每秒10个,突发1

for i := 0; i < 100; i++ { limiter.Wait(context.Background()) go func(id int) { fmt.Printf("执行任务 %d\n", id) }(i) }

注意:这种方式控制的是请求发起速率,不直接限制并发数,适合API调用等场景。

选择哪种方式取决于需求:控制最大并发数用channel或WeightedSemaphore;控制请求频率用rate.Limiter。实际项目中常组合使用,比如先限频再限并发。

基本上就这些,关键点是理解不同工具的适用场景,避免过度设计。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

182

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

229

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

343

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

210

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

396

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

240

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

194

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

458

2025.06.17

C++ 设计模式与软件架构
C++ 设计模式与软件架构

本专题深入讲解 C++ 中的常见设计模式与架构优化,包括单例模式、工厂模式、观察者模式、策略模式、命令模式等,结合实际案例展示如何在 C++ 项目中应用这些模式提升代码可维护性与扩展性。通过案例分析,帮助开发者掌握 如何运用设计模式构建高质量的软件架构,提升系统的灵活性与可扩展性。

0

2026.01.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 4.4万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号