Golang并发写入文件方法解析

package main
import (
"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()
}

package main
import (
"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)

// 消费者自动退出
}