Golang异步写入文件方法详解

package main
import (
"log""os"
)
func asyncWrite(filename, data string) {
go func() {
if err := os.WriteFile(filename, []byte(data), 0644); err != nil {
log.Printf("写入文件失败: %v", err)
}
}()
}

type writeTask struct {
    filename string
    data     []byte
}
var writeQueue = make(chan writeTask, 100) // 缓冲队列
func init() {
go func() {
for task := range writeQueue {
if err := os.WriteFile(task.filename, task.data, 0644); err != nil {
log.Printf("异步写入失败: %v", err)
}
}
}()
}
func enqueueWrite(filename string, data string) {
writeQueue <- writeTask{filename: filename, data: []byte(data)}
}

var buffer = make([]writeTask, 0, 100)
var mu sync.Mutex
func init() {
ticker := time.NewTicker(2 * time.Second)
go func() {
for range ticker.C {
flushBuffer()
}
}()
}
func bufferedWrite(filename, data string) {
mu.Lock()
defer mu.Unlock()
buffer = append(buffer, writeTask{filename, []byte(data)})
}
func flushBuffer() {
mu.Lock()
tasks := buffer
buffer = make([]writeTask, 0, 100)
mu.Unlock()
<span style="color:#0000ff;">for</span> _, task := <span style="color:#0000ff;">range</span> tasks {
    <span style="color:#0000ff;">if</span> err := os.WriteFile(task.filename, task.data, 0644); err != nil {
        log.Printf(<span style="color:#a31515;">"批量写入失败: %v"</span>, err)
    }
}
}