0

0

解析Golang中的栅栏模式(Barrier) Go语言同步多个并发任务的执行点

P粉602998670

P粉602998670

发布时间:2026-03-13 11:04:01

|

861人浏览过

|

来源于php中文网

原创

Go 标准库无内置 sync.Barrier,需用 sync.WaitGroup(预设计数)、sync.Mutex+sync.Cond(支持复用)或 channel(需严格配对收发)实现;真实场景中多被 WaitGroup 或 context 模式替代。

解析golang中的栅栏模式(barrier) go语言同步多个并发任务的执行点

Go 里没有内置 Barrier,得自己造

Go 标准库确实没提供 sync.Barrier 这种类型。你搜 sync.Barrier 会 404,不是你环境坏了,是它压根不存在。想让 N 个 goroutine 在某个点齐步走,得靠 sync.WaitGroup + sync.Mutexsync.Cond 组合实现,或者用 channel 配合计数器。别试图 import 一个不存在的包。

sync.WaitGroup 模拟 Barrier 最轻量

这是最常用、也最容易理解的做法:每个 goroutine 到达栅栏时调用 wg.Add(1)(注意不是初始化时加),然后 wg.Wait() 等待全部到达;等所有都到了,再统一 wg.Done() 清零。但直接这么写会死锁 —— 因为 wg.Wait() 必须在所有 Add 之后调用,而 goroutine 是并发的。

正确做法是预设参与数,用两次 WaitGroup:

  • 第一次 wg1 用于“登记到达”,每个 goroutine 执行 wg1.Done() 表示我到了
  • 主线程等 wg1.Wait() 完成后,再用 wg2 触发下一轮(比如广播信号)
  • 或者更干脆:用一个 sync.Mutex + 计数器 + sync.Cond,避免多次 WaitGroup 嵌套

简单示意(无锁版,适合固定 N):

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

var (
    mu    sync.Mutex
    count int
    cond  *sync.Cond
)
func init() {
    cond = sync.NewCond(&mu)
}
func barrier(n int) {
    mu.Lock()
    count++
    if count == n {
        cond.Broadcast() // 全齐了,喊所有人继续
        count = 0        // 重置,支持复用
    } else {
        cond.Wait() // 没齐,先睡
    }
    mu.Unlock()
}

channel 实现 Barrier 容易卡死

有人喜欢用带缓冲 channel 当信号灯:开一个 make(chan struct{}, N),每个 goroutine 到达时塞一个 struct{},等第 N 个塞完,再从 channel 里读 N 次清空它。问题在于:如果某个 goroutine panic 或提前退出,channel 就永远塞不满,其余 goroutine 全卡在 ch <- struct{}{} 上。

Mokker AI
Mokker AI

AI产品图添加背景

下载

更糟的是,如果多个栅栏连续用,没清空 channel 就进下一轮,行为完全不可控。

  • 必须确保所有参与者严格执行“发送 + 接收”配对
  • 不能依赖 defer 清理,因为 defer 在 panic 后才跑,来不及救场
  • 缓冲大小必须等于预期 goroutine 数,错一个就阻塞
  • 性能上比 sync.Cond 略差,毕竟涉及 goroutine 调度和 channel runtime 开销

真实场景中,Barrier 很少单独存在

你几乎不会为了“齐步走”而专门写个栅栏。它通常藏在更上层的模式里:

  • 批处理任务分片后并行计算,最后汇总 —— 这时用 sync.WaitGroup 更自然
  • 测试里要等所有 goroutine 启动完毕再开始打点 —— 可用 sync.Once + channel 通知
  • 热重启时等待旧请求处理完再关服务 —— 这是 context.WithTimeout + WaitGroup 的组合

硬套 Barrier 模型反而增加复杂度。Go 的哲学是“用 channel 和 goroutine 组合表达意图”,而不是复刻 Java/C++ 里的同步原语。

真正容易被忽略的点是:栅栏一旦复用,就必须考虑重入安全和状态清理。比如 sync.CondWait() 返回后,条件未必仍成立(spurious wakeup),得在外层加 for 循环检查;而 WaitGroupAdd() 不能在 Wait() 后调用,否则 panic。这些边界,不跑压测根本看不出问题。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

WorkBuddy
WorkBuddy

腾讯云推出的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 :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

211

2024.02.23

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

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

247

2024.02.23

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

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

356

2024.02.23

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

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

214

2024.03.05

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

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

409

2024.05.21

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

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

490

2025.06.09

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

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

201

2025.06.10

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

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

1479

2025.06.17

Python异步编程与Asyncio高并发应用实践
Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开,深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例,帮助开发者掌握 Python 在高并发场景中的高效开发方法,并提升系统资源利用率与整体运行性能。

37

2026.03.12

热门下载

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

精品课程

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

共32课时 | 6.2万人学习

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

共10课时 | 0.9万人学习

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

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