使用互斥锁或通道可避免Go中多goroutine写文件冲突。1. 互斥锁（sync.Mutex）确保同一时间仅一个goroutine写入；2. 通道（channel）将写请求序列化，由单一goroutine处理；3. 结合bufio.Writer可提升高并发写入性能。
在Go语言中，多个goroutine同时写入同一个文件会导致数据混乱或覆盖，必须通过同步机制避免冲突。最常用的方式是使用互斥锁（sync.Mutex）来保证同一时间只有一个goroutine能执行写操作。
使用 Mutex 控制并发写入
通过引入 sync.Mutex，可以在写文件的临界区加锁，确保线程安全。
示例代码：
package mainimport ("os""sync")
var (file *os.Filemu sync.Mutexwg sync.WaitGroup)
func initFile(filename string) {f, err := os.OpenFile(filename, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)if err != nil {panic(err)}file = f}
func writeData(data string) {defer wg.Done()
mu.Lock()defer mu.Unlock()file.WriteString(data + "n")
}
立即学习“go语言免费学习笔记（深入）”；
func main() {initFile("output.txt")defer file.Close()
for i := 0; i < 10; i++ { wg.Add(1) go writeData("data from goroutine " + string(rune('0'+i)))}wg.Wait()
}
使用 channel 序列化写操作
另一种方式是将所有写请求发送到一个channel，由单独的goroutine顺序处理，从而避免竞争。
这种方式更适用于需要控制写入顺序或批量写入的场景。
示例：
package mainimport ("bufio""os")
func writeFileWithChannel() {messages := make(chan string, 10)file, _ := os.Create("output.txt")defer file.Close()
writer := bufio.NewWriter(file)defer writer.Flush()// 单独的写协程go func() { for msg := range messages { writer.WriteString(msg + "n") }}()// 模拟多个生产者var wg sync.WaitGroupfor i := 0; i < 10; i++ { wg.Add(1) go func(id int) { defer wg.Done() messages <- "message from " + string(rune('0'+id)) }(i)}wg.Wait()close(messages)
}
选择合适的方法
两种方式各有适用场景：
Mutex 简单直接，适合已有文件句柄且并发量不高的情况Channel 模型更清晰，利于解耦和扩展，适合高并发或需控制写入节奏的场景如果写入频率很高，建议结合 buffer（如 bufio.Writer）提升性能
基本上就这些，关键是不让多个goroutine直接操作同一个文件句柄。
以上就是Golang如何处理多goroutine写文件冲突的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1418018.html
微信扫一扫 
支付宝扫一扫 
