Golang如何处理多goroutine写文件冲突-Golang-PHP中文网

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

P粉602998670

发布： 2025-10-28 09:02:01

原创

313人浏览过

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

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

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

使用 Mutex 控制并发写入

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

示例代码：

package main
<p>import (
"os"
"sync"
)</p><p>var (
file *os.File
mu   sync.Mutex
wg   sync.WaitGroup
)</p><p>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
}</p><p>func writeData(data string) {
defer wg.Done()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">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顺序处理，从而避免竞争。

知网AI智能写作

知网AI智能写作，写文档、写报告如此简单

查看详情

这种方式更适用于需要控制写入顺序或批量写入的场景。

示例：

package main
<p>import (
"bufio"
"os"
)</p><p>func writeFileWithChannel() {
messages := make(chan string, 10)
file, _ := os.Create("output.txt")
defer file.Close()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">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)

登录后复制

}