Golang如何处理多goroutine写文件冲突

使用互斥锁或通道可避免Go中多goroutine写文件冲突。1. 互斥锁（sync.Mutex）确保同一时间仅一个goroutine写入；2. 通道（channel）将写请求序列化，由单一goroutine处理；3. 结合bufio.Writer可提升高并发写入性能。

在Go语言中，多个goroutine同时写入同一个文件会导致数据混乱或覆盖，必须通过同步机制避免冲突。最常用的方式是使用互斥锁（sync.Mutex）来保证同一时间只有一个goroutine能执行写操作。

使用 Mutex 控制并发写入

通过引入 sync.Mutex，可以在写文件的临界区加锁，确保线程安全。

示例代码：

package main
import (
"os"
"sync"
)
var (
file *os.File
mu   sync.Mutex
wg   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顺序处理，从而避免竞争。

							

								
								

									微信 WeLM
									
WeLM不是一个直接的对话机器人，而是一个补全用户输入信息的生成模型。
								
								下载 
							
						
这种方式更适用于需要控制写入顺序或批量写入的场景。
示例：
package main
import (
"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.WaitGroup
for 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直接操作同一个文件句柄。