Golang如何处理多goroutine写入同一文件_Golang 多goroutine文件写入实践-Golang-PHP中文网

Golang如何处理多goroutine写入同一文件_Golang 多goroutine文件写入实践

P粉602998670

发布： 2025-11-17 18:23:02

原创

452人浏览过

使用互斥锁、通道或带缓冲的写入可安全处理多goroutine文件写入。1. sync.Mutex确保写操作互斥，简单但可能有性能瓶颈；2. 通过channel将写请求发送至单一协程，实现串行化写入，适合高并发日志场景；3. 结合bufio.Writer与锁减少系统调用，提升性能，需注意调用Flush()防止数据丢失。应避免无保护的并发写入。

golang如何处理多goroutine写入同一文件_golang 多goroutine文件写入实践

多个goroutine同时写入同一文件时，如果不加控制，会导致内容混乱、覆盖或数据损坏。Golang本身不提供内置的文件写锁机制，因此需要开发者通过同步手段来保证写操作的安全性。以下是几种常见且有效的处理方式。

使用互斥锁（sync.Mutex）保护文件写入

最直接的方法是用 sync.Mutex 来确保同一时间只有一个goroutine能执行写操作。

示例代码：

package main
<p>import (
"os"
"sync"
)</p><p>func main() {
file, err := os.OpenFile("output.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
panic(err)
}
defer file.Close()</p><pre class='brush:php;toolbar:false;'>var mu sync.Mutex
var wg sync.WaitGroup

for i := 0; i < 10; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        msg := []byte{byte('0' + id), '\n'}

        mu.Lock()
        file.Write(msg)
        mu.Unlock()
    }(i)
}

wg.Wait()

登录后复制

}

文希AI写作

AI论文写作平台

130

查看详情

立即学习“go语言免费学习笔记（深入）”；

这个方法简单可靠，适用于大多数场景。但注意：如果频繁写入，锁竞争可能成为性能瓶颈。

通过通道（channel）串行化写操作

将所有写请求发送到一个专用的“写协程”，由它统一写入文件，避免并发访问。

优点是逻辑清晰，解耦生产与写入过程，适合高并发日志等场景。

package main
<p>import (
"os"
)</p><p>func writeTo(file *os.File, ch <-chan []byte) {
for data := range ch {
file.Write(data)
}
}</p><p>func main() {
file, _ := os.OpenFile("output.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
defer file.Close()</p><pre class='brush:php;toolbar:false;'>ch := make(chan []byte, 100)
go writeTo(file, ch)

for i := 0; i < 10; i++ {
    ch <- []byte{byte('0' + i), '\n'}
}
close(ch)

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

这种方式天然避免了锁的使用，结构更安全，尤其适合异步日志系统设计。

使用带缓冲的io.Writer配合锁

为了提升性能，可以在文件写入时使用 bufio.Writer 缓冲数据，减少系统调用次数，但仍需加锁保护。

示例：

package main
<p>import (
"bufio"
"os"
"sync"
)</p><p>func main() {
file, _ := os.OpenFile("output.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
defer file.Close()</p><pre class='brush:php;toolbar:false;'>writer := bufio.NewWriter(file)
var mu sync.Mutex
var wg sync.WaitGroup

for i := 0; i < 10; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        mu.Lock()
        writer.WriteString(string(byte('0'+id)) + "\n")
        mu.Unlock()
    }(i)
}

wg.Wait()
writer.Flush() // 必须手动刷新缓冲区

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

注意：即使使用缓冲，也要在程序结束前调用 Flush()，否则数据可能丢失。

基本上就这些。选择哪种方式取决于你的性能要求和使用场景。对于多数情况，互斥锁足够；若追求高并发和解耦，推荐通道方案。关键是不能让多个goroutine无保护地写同一个文件描述符。

以上就是Golang如何处理多goroutine写入同一文件_Golang 多goroutine文件写入实践的详细内容，更多请关注php中文网其它相关文章！