使用互斥锁可确保多goroutine安全写入同一文件,通过sync.Mutex实现原子操作;采用channel结合生产者-消费者模型能提升效率与可扩展性,由单一goroutine集中写入;若无需共用文件,可让每个goroutine写独立文件最后合并,避免竞争。

Go语言通过goroutine和channel机制天然支持高并发编程,实现并发文件写入时需要考虑数据一致性、写入顺序以及文件锁等问题。直接让多个goroutine同时写同一个文件会导致内容错乱,因此要结合同步机制或集中写入策略来安全操作。
使用互斥锁(sync.Mutex)控制并发写入
当多个goroutine需要向同一文件写入数据时,最简单的方式是用sync.Mutex保证同一时间只有一个goroutine在执行写操作。
示例代码:
package mainimport ( "os" "sync" )
func main() { file, err := os.OpenFile("output.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644) if err != nil { panic(err) } defer file.Close()
var mu sync.Mutex var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go func(id int) { defer wg.Done() data := []byte("goroutine " + string(rune('0'+id)) + " writing\n") mu.Lock() file.Write(data) mu.Unlock() }(i) } wg.Wait()}
立即学习“go语言免费学习笔记(深入)”;
说明:每次写入前获取锁,写完释放,确保写操作原子性。适合写入频率不高但并发量大的场景。
通过channel集中写入(生产者-消费者模型)
更高效且可扩展的做法是使用一个单独的写入goroutine负责实际写文件,其他goroutine通过channel发送数据给它。
优点:避免频繁加锁,写入顺序可控,易于添加缓冲和错误处理。
云模块_YunMOK网站管理系统采用PHP+MYSQL为编程语言,搭载自主研发的模块化引擎驱动技术,实现可视化拖拽无技术创建并管理网站!如你所想,无限可能,支持创建任何网站:企业、商城、O2O、门户、论坛、人才等一块儿搞定!永久免费授权,包括商业用途; 默认内置三套免费模板。PC网站+手机网站+适配微信+文章管理+产品管理+SEO优化+组件扩展+NEW Login界面.....目测已经遥遥领先..
package mainimport ( "bufio" "os" )
func main() { file, err := os.OpenFile("output.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644) if err != nil { panic(err) } defer file.Close()
writer := bufio.NewWriter(file) defer writer.Flush() dataChan := make(chan string, 100) // 缓冲channel var wg sync.WaitGroup // 启动消费者:写入文件 go func() { for line := range dataChan { writer.WriteString(line + "\n") } }() // 启动多个生产者 for i := 0; i < 10; i++ { wg.Add(1) go func(id int) { defer wg.Done() for j := 0; j < 5; j++ { dataChan <- "data from worker " + string(rune('0'+id)) } }(i) } // 所有生产者结束后关闭channel wg.Wait() close(dataChan) // 消费者自动退出}
立即学习“go语言免费学习笔记(深入)”;
说明:利用bufio.Writer提升IO性能,所有写请求通过channel传递,由单个goroutine统一处理。
按协程分文件写入(无竞争方式)
如果不需要所有数据写入同一个文件,可以让每个goroutine写独立的临时文件,最后合并。这种方式完全避免并发冲突。
适用场景:日志切片、批量数据导出等。
示例思路:
- 每个goroutine生成自己的文件名(如 output_1.tmp, output_2.tmp)
- 各自并发写入不加锁
- 全部完成后使用os.Append或命令行工具合并
基本上就这些常见模式。选择哪种方式取决于是否必须共用一个文件、性能要求和数据顺序需求。用互斥锁最直观,用channel更符合Go的哲学,分文件写法则能最大化并发效率。









