BufferedWriter 在同时使用时不起作用

Question

我需要同时将大量数据从多个 goroutines（比如 30 个）写入文本文件。我所做的是：

workers.Add(core.Concurrency)
    for i := 0; i < core.Concurrency; i++ {
        go func() {
            defer workers.Done()
            writer := bufio.NewWriter(f)
            defer writer.Flush()
            a.Worker(workChan, writer)
        }()
    }

但这在某些情况下似乎不起作用。这里 f 是 *os.File 对象。在某些情况下，这根本不会写入文件，在某些情况下，它会写入一些数据，但不会在以后写入。行为非常不一致，也没有错误。

知道为什么会这样吗？

Answer 1

问题是您有多个 goroutine 试图一次写入一个文件，没有任何同步。这将导致不可预测的输出顺序，并可能丢失写入。在此基础上使用缓冲 I/O 只会帮助掩盖行为。

最好的解决方案是启动一个写入输出的 goroutine（有或没有缓冲 I/O，取决于您的需要），并让您的所有工作人员发送要写入的数据通过通道写入 goroutine。

BufferedWriter 在同时使用时不起作用

BufferedWriter doesn't works when used concurrently

go

concurrency

writer

buffered