Go中bufio.Reader不是并发安全的。
bufio.Reader 并非并发安全,其内部状态(如读取偏移量和缓冲区)在多 goroutine 同时调用 Read 等方法时会引发数据竞争、脏读、越界 panic 等严重问题;正确用法必须显式加锁、为每个 goroutine 独立创建新实例,或通过 channel 串行化读取——忽视这一点轻则逻辑错乱,重则程序崩溃,是 Go 开发中极易踩坑却常被忽略的关键细节。

bufio.Reader不是goroutine安全的,多个goroutine同时调用其Read方法会导致数据竞争和未定义行为;必须通过外部同步机制(如互斥锁、channel或单goroutine串行读取)确保同一实例仅被一个goroutine访问。
bufio.Reader不是goroutine安全的,多个goroutine同时调用其Read方法会导致数据竞争和未定义行为;必须通过外部同步机制(如互斥锁、channel或单goroutine串行读取)确保同一实例仅被一个goroutine访问。
bufio.Reader 是 Go 标准库中用于带缓冲读取的核心类型,它通过内部字节切片(buf)和读取位置指针(rd, r, w 等字段)提升 I/O 效率。但其设计目标是单 goroutine 使用场景——所有公开方法(如 Read, ReadByte, ReadString, Peek, Discard)均会修改内部状态,尤其是读取偏移量 r 和缓冲区填充状态。例如,Read(p []byte) 在返回前会更新 r += n,而 fill() 操作则重置 r = 0 并移动 w。若两个 goroutine 并发调用 Read,可能引发以下问题:
- 竞态读取:goroutine A 读到一半时被调度,goroutine B 调用 fill() 清空并重填缓冲区,导致 A 继续读取脏数据或越界;
- 偏移错乱:r 字段非原子更新,造成读取位置丢失或重复读取;
- panic 风险:内部切片操作(如 buf[r:w])在竞态下可能触发 index out of range。
✅ 正确做法示例:
方案一:使用 sync.Mutex 保护(适用于共享 reader 的多任务场景)
var (
reader = bufio.NewReader(os.Stdin)
mu sync.Mutex
)
func safeRead(p []byte) (n int, err error) {
mu.Lock()
defer mu.Unlock()
return reader.Read(p)
}方案二:每个 goroutine 独立构造 reader(推荐,零开销且语义清晰)
// 每个 goroutine 自行封装底层 io.Reader
go func(r io.Reader) {
br := bufio.NewReader(r) // 新实例,无共享状态
buf := make([]byte, 1024)
for {
n, err := br.Read(buf)
if err != nil {
break
}
// 处理 buf[:n]
}
}(fileOrConn)方案三:通过 channel 串行化读取(适合需顺序解析的流水线)
ch := make(chan []byte, 10)
go func() {
br := bufio.NewReader(src)
buf := make([]byte, 1024)
for {
n, err := br.Read(buf)
if err != nil {
close(ch)
return
}
ch <- append([]byte(nil), buf[:n]...)
}
}()
// 所有消费者从 ch 有序读取
for data := range ch {
process(data)
}⚠️ 注意事项:
- bufio.Scanner 同样不支持并发调用 Scan(),因其内部也依赖 *bufio.Reader 的状态;
- 不要试图通过 atomic 或 unsafe 手动“修复” bufio.Reader 的并发性——其状态耦合度高,无法安全拆解;
- 若需高性能并发读取,应优先考虑将数据源本身分片(如文件按 offset 切分),或使用无状态解析器(如 encoding/json.Decoder 配合独立 reader)。
总之,bufio.Reader 的非并发安全是明确的设计约定,而非缺陷。遵循“共享内存不如通信,通信不如独占”的 Go 并发哲学,合理分配 reader 实例或引入轻量同步,才是健壮、可维护的实践路径。
以上就是《Go中bufio.Reader不是并发安全的。》的详细内容,更多关于的资料请关注golang学习网公众号!
墨墨背单词重置方法全解析
- 上一篇
- 墨墨背单词重置方法全解析
- 下一篇
- Sass变量覆盖,实现原子化CSS组件设计
-
- Golang · Go教程 | 8小时前 | 并发 · Go教程 · trace.NewTask go tool trace Go runtime/trace 执行跟踪 trace.WithRegion
- Go runtime/trace 怎样按任务标记跟踪区间
- 391浏览 收藏
-
- Golang · Go教程 | 8小时前 | flag · go · Go 命令行参数 flag.TextVar encoding.TextUnmarshaler
- Go flag.TextVar 怎样把自定义类型接入命令行
- 184浏览 收藏
-
- Golang · Go教程 | 10小时前 | 错误处理 · 模板 · Go教程 · html/template · 模板渲染 Go html/template missingkey 模板缺失字段 Execute错误
- Go html/template 缺失字段的严格渲染配置与错误处理
- 371浏览 收藏
-
- Golang · Go教程 | 10小时前 | html · go · 模板 · url · Go html/template 自动转义 URL上下文 template.URL
- Go html/template 怎样避免 URL 上下文误用
- 326浏览 收藏
-
- Golang · Go教程 | 10小时前 |
- Go text/template.ParseFS 怎样加载嵌入文件模板
- 208浏览 收藏
-
- Golang · Go教程 | 10小时前 |
- Go database/sql.NamedArg 怎样给 SQL 参数命名
- 311浏览 收藏
-
- Golang · Go教程 | 10小时前 | HTTP · go · Gin · Gin ShouldBindBodyWith 请求体重复绑定 ShouldBind binding.JSON
- Gin ShouldBindBodyWith 怎么让同一个请求体绑定两次
- 134浏览 收藏
-
- Golang · Go教程 | 11小时前 | go · 文件系统 · Go os.ReadDir Go File.ReadDir Go DirEntry Go 目录遍历
- Go os.ReadDir 怎样高效读取目录条目
- 269浏览 收藏
-
- Golang · Go教程 | 11小时前 | go · Go go/types.Config Go Importer Go 类型检查 types.Check
- Go go/types.Config 怎样给类型检查接入导入器
- 222浏览 收藏
-
- Golang · Go教程 | 11小时前 |
- Go maphash.Hash 怎样用固定种子复现哈希结果
- 341浏览 收藏
-
- Golang · Go教程 | 11小时前 | Go 字节切片 encoding/binary AppendByteOrder
- Go binary.ByteOrder.Append 怎样把整数追加到现有字节切片
- 373浏览 收藏
-
- Golang · Go教程 | 12小时前 | go · IPv6 Go ipv4 netip.ParsePrefix CIDR
- Go netip.ParsePrefix 怎样解析 CIDR 字符串
- 334浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 568次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 614次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 641次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 601次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 418次使用
-
- Java 性能优化上线清单:从定位、改造到灰度发布
- 2026-06-11 860浏览
-
- Spring Boot 压测验证:Gatling、JMeter 与性能回归门禁
- 2026-06-11 843浏览
-
- Java NMT 非堆内存排查:Direct Buffer、线程栈与 Metaspace 分析
- 2026-06-11 826浏览
-
- Spring Boot 容器内存优化:JVM 堆、非堆与 MaxRAMPercentage
- 2026-06-11 809浏览
-
- Tomcat 连接与线程参数调优:maxThreads、acceptCount 与 KeepAlive
- 2026-06-11 792浏览

